diff --git a/fink_mm/__init__.py b/fink_mm/__init__.py index 338734d1..b2c0f6cf 100644 --- a/fink_mm/__init__.py +++ b/fink_mm/__init__.py @@ -12,6 +12,6 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. -__version__ = "0.16.12" +__version__ = "0.16.13" __distribution_schema_version__ = "1.3" __observatory_schema_version__ = "1.1" diff --git a/fink_mm/utils/fun_utils.py b/fink_mm/utils/fun_utils.py index 6dd99302..fc9a3a13 100644 --- a/fink_mm/utils/fun_utils.py +++ b/fink_mm/utils/fun_utils.py @@ -14,11 +14,16 @@ from fink_utils.spark.utils import concat_col from fink_mm.observatory import obsname_to_class, INSTR_FORMAT -from fink_mm.observatory.observatory import Observatory from fink_mm.gcn_stream.gcn_reader import load_voevent_from_file, load_json_from_file from fink_mm.init import init_logging from enum import Enum +# FIXME +# commented due to a chaining import leading to a pandera import +# pandera break the spark jobs by adding the SPARK_LOCAL_IP env variable into the environment +# link to the issue: https://github.com/FusRoman/fink-mm/issues/107#issue-2108208253 +# from fink_mm.observatory.observatory import Observatory + # from fink_broker.tracklet_identification import add_tracklet_information @@ -265,7 +270,7 @@ def sub_compute_rate( return abs_rate, norm_rate, first_variation_time, diff_start_hist, from_upper -def get_observatory(obsname: str, rawEvent: str) -> Observatory: +def get_observatory(obsname: str, rawEvent: str): # -> Observatory """ Get the observatory class from an observatory name and a raw voevent