From cc2588c6216e0eda7a67339187d24f087bc2dbcc Mon Sep 17 00:00:00 2001 From: Pedro Gallardo Date: Fri, 17 Nov 2023 10:08:13 -0300 Subject: [PATCH 1/5] refactor: changed how ps1 catalog is updated --- metadata_step/metadata_step/step.py | 18 ++++++++---- metadata_step/metadata_step/utils/database.py | 29 +++++++++++-------- metadata_step/metadata_step/utils/parse.py | 14 +++------ 3 files changed, 33 insertions(+), 28 deletions(-) diff --git a/metadata_step/metadata_step/step.py b/metadata_step/metadata_step/step.py index 6adadb7b5..d749c1d13 100644 --- a/metadata_step/metadata_step/step.py +++ b/metadata_step/metadata_step/step.py @@ -1,4 +1,4 @@ -from typing import Dict, List +from typing import Dict, List, Tuple from apf.core.step import GenericStep from metadata_step.utils.parse import format_detection @@ -24,9 +24,14 @@ def _format_detection(self, d: Dict, catalogs: Dict): extra_fields.pop("prv_candidates", {}) return format_detection({**d, **extra_fields}, catalogs) - def _write_metadata_into_db(self, result: List[Dict]): + def _write_metadata_into_db(self, result: List[Dict], ps1: Dict[List]): + ps1_updates = [] + for el in ps1.values(): + if el["updated"]: + ps1_updates.append(el) + with self.db.session() as session: - insert_metadata(session, result) + insert_metadata(session, result, ps1_updates) session.commit() # Output format: [{oid: OID, ss: SS_DATA, ...}] @@ -40,8 +45,9 @@ def execute(self, messages: List[Dict]): catalogs["gaia"] = get_gaia_catalog(session, oids) result = [self._format_detection(message, catalogs) for message in messages] - return result + return result, catalogs["ps1"] - def post_execute(self, result: List[Dict]): - self._write_metadata_into_db(result) + def post_execute(self, result: Tuple[List[Dict], List[Dict]]): + data, ps1 = result + self._write_metadata_into_db(data, ps1) return [] diff --git a/metadata_step/metadata_step/utils/database.py b/metadata_step/metadata_step/utils/database.py index 79aac25b3..65dd79f70 100644 --- a/metadata_step/metadata_step/utils/database.py +++ b/metadata_step/metadata_step/utils/database.py @@ -3,7 +3,7 @@ from contextlib import contextmanager from typing import Callable, ContextManager, Dict, List -from sqlalchemy import create_engine, select +from sqlalchemy import create_engine, select, update from sqlalchemy.dialects.postgresql import insert from sqlalchemy.orm import sessionmaker, Session from db_plugins.db.sql.models import Reference, Gaia_ztf, Ss_ztf, Dataquality, Ps1_ztf @@ -50,6 +50,12 @@ def _parse_sql_dict(d: Dict): return {k: _none_to_nan(v) for k, v in d.items() if not k.startswith("_")} +def _parse_ps1(d: Dict): + parsed = _parse_sql_dict(d) + parsed["updated"] = False + return parsed + + def _create_hashmap(catalog: List[Dict]): hashmap: Dict[List] = {} for item in catalog: @@ -63,7 +69,7 @@ def _create_hashmap(catalog: List[Dict]): def get_ps1_catalog(session: Session, oids: List): stmt = select(Ps1_ztf).where(Ps1_ztf.oid.in_(oids)) catalog = session.execute(stmt).all() - return _create_hashmap([_parse_sql_dict(c[0].__dict__) for c in catalog]) + return _create_hashmap([_parse_ps1(c[0].__dict__) for c in catalog]) def get_gaia_catalog(session: Session, oids: List): @@ -79,12 +85,12 @@ def _accumulate(data: List): acc["dataquality"].append(d["dataquality"]) acc["reference"].append(d["reference"]) acc["gaia"].append(d["gaia"]) - acc["ps1"].extend(d["ps1"]) + acc["ps1"].append(d["ps1"]) return acc -def insert_metadata(session: Session, data: List): +def insert_metadata(session: Session, data: List, ps1_updates: List): accumulated_metadata = _accumulate(data) # Reference reference_stmt = insert(Reference).values(accumulated_metadata["reference"]) @@ -115,12 +121,11 @@ def insert_metadata(session: Session, data: List): # PS1 ps1_data = list({el["candid"]: el for el in accumulated_metadata["ps1"]}.values()) ps1_stmt = insert(Ps1_ztf).values(ps1_data) - ps1_stmt = ps1_stmt.on_conflict_do_update( - constraint="ps1_ztf_pkey", - set_=dict( - unique1=ps1_stmt.excluded.unique1, - unique2=ps1_stmt.excluded.unique2, - unique3=ps1_stmt.excluded.unique3, - ), - ) session.connection().execute(ps1_stmt) + + for el in ps1_updates: + session.connection().execute( + update(Ps1_ztf) + .where(Ps1_ztf.candid == el["candid"]) + .values(unique1=el["unique1"], unique2=el["unique2"], unique3=el["unique3"]) + ) diff --git a/metadata_step/metadata_step/utils/parse.py b/metadata_step/metadata_step/utils/parse.py index 5d972b90b..274c1e950 100644 --- a/metadata_step/metadata_step/utils/parse.py +++ b/metadata_step/metadata_step/utils/parse.py @@ -81,16 +81,10 @@ def format_ps1(alert: Dict, catalog={}): continue for ps1_aux in ps1_filtered: - candid = ps1_aux["candid"] - saved = candids.get(candid) - if not saved: - saved = ps1_aux.copy() - saved[f"unique{i}"] = False - candids[candid] = saved - # new_ps1.extend(list(candids.values())) - - new_ps1.append(alert) - return new_ps1 + ps1_aux[f"unique{i}"] = False + ps1_aux["updated"] = True + + return alert # formats each alert to send it to scribe psql From 0c55f7064ff19bd319c8cca83c10c837bbb85cf6 Mon Sep 17 00:00:00 2001 From: Pedro Gallardo Date: Fri, 17 Nov 2023 10:14:50 -0300 Subject: [PATCH 2/5] test: fixed db testing --- metadata_step/tests/integration/test_database.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/metadata_step/tests/integration/test_database.py b/metadata_step/tests/integration/test_database.py index 70a17a8b4..77bb3ec10 100644 --- a/metadata_step/tests/integration/test_database.py +++ b/metadata_step/tests/integration/test_database.py @@ -95,7 +95,7 @@ def test_metadata_insertion(psql_service): ] with conn.session() as session: - insert_metadata(session, data) + insert_metadata(session, data, []) session.commit() # perform queries to make sure they were inserted/updated ss_result = session.execute(select(Ss_ztf).where(Ss_ztf.oid == "ZTF00llmn")) From 74c1a5c2316fd1067304272ae79245a4ada0c640 Mon Sep 17 00:00:00 2001 From: Pedro Gallardo Date: Fri, 17 Nov 2023 10:18:30 -0300 Subject: [PATCH 3/5] fix: type hinting --- metadata_step/metadata_step/step.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/metadata_step/metadata_step/step.py b/metadata_step/metadata_step/step.py index d749c1d13..016b47923 100644 --- a/metadata_step/metadata_step/step.py +++ b/metadata_step/metadata_step/step.py @@ -24,7 +24,7 @@ def _format_detection(self, d: Dict, catalogs: Dict): extra_fields.pop("prv_candidates", {}) return format_detection({**d, **extra_fields}, catalogs) - def _write_metadata_into_db(self, result: List[Dict], ps1: Dict[List]): + def _write_metadata_into_db(self, result: List[Dict], ps1: Dict[str, List]): ps1_updates = [] for el in ps1.values(): if el["updated"]: From 50cd291c842192469af6dbbac208fca16aabcb8a Mon Sep 17 00:00:00 2001 From: Pedro Gallardo Date: Fri, 17 Nov 2023 10:38:25 -0300 Subject: [PATCH 4/5] fix: new ps1 updating strategy --- metadata_step/metadata_step/step.py | 3 ++- metadata_step/tests/data/mocks.py | 11 ----------- metadata_step/tests/integration/test_database.py | 8 ++++---- 3 files changed, 6 insertions(+), 16 deletions(-) diff --git a/metadata_step/metadata_step/step.py b/metadata_step/metadata_step/step.py index 016b47923..f8d43ecdc 100644 --- a/metadata_step/metadata_step/step.py +++ b/metadata_step/metadata_step/step.py @@ -26,7 +26,8 @@ def _format_detection(self, d: Dict, catalogs: Dict): def _write_metadata_into_db(self, result: List[Dict], ps1: Dict[str, List]): ps1_updates = [] - for el in ps1.values(): + flattened = sum(ps1.values(), []) + for el in flattened: if el["updated"]: ps1_updates.append(el) diff --git a/metadata_step/tests/data/mocks.py b/metadata_step/tests/data/mocks.py index ad9c4e4be..48ce8fc3b 100644 --- a/metadata_step/tests/data/mocks.py +++ b/metadata_step/tests/data/mocks.py @@ -95,17 +95,6 @@ ] ps1_mocks = [ - { - "oid": "ZTF00llmn", - "candid": 987654321, - "objectidps1": 55.55, - "objectidps2": 44.44, - "objectidps3": 33.33, - "nmtchps": 1, - "unique1": True, - "unique2": True, - "unique3": True, - }, { "oid": "ZTF00llmn", "candid": 1234567890, diff --git a/metadata_step/tests/integration/test_database.py b/metadata_step/tests/integration/test_database.py index 77bb3ec10..673b002b9 100644 --- a/metadata_step/tests/integration/test_database.py +++ b/metadata_step/tests/integration/test_database.py @@ -68,7 +68,7 @@ def test_metadata_insertion(psql_service): "nframesref": 1, }, "dataquality": { - "candid": 1234567890, + "candid": 987654321, "oid": "ZTF00llmn", "fid": 1, "xpos": 0, @@ -80,9 +80,9 @@ def test_metadata_insertion(psql_service): "neargaia": 55.55, "unique1": False, }, - "ps1": [{ + "ps1": { "oid": "ZTF00llmn", - "candid": 1234567890, + "candid": 987654321, "objectidps1": 15.11, "objectidps2": 25.22, "objectidps3": 35.33, @@ -90,7 +90,7 @@ def test_metadata_insertion(psql_service): "unique1": True, "unique2": True, "unique3": True, - }], + }, } ] From c2f4a0604148e3a15bea6709f0bfb6116088d3e5 Mon Sep 17 00:00:00 2001 From: "@alerceadmin" Date: Fri, 17 Nov 2023 13:54:49 +0000 Subject: [PATCH 5/5] chore: update version --- alert_archiving_step/pyproject.toml | 2 +- charts/alert_archiving_step/Chart.yaml | 4 ++-- charts/correction_step/Chart.yaml | 4 ++-- charts/early_classification_step/Chart.yaml | 4 ++-- charts/feature_step/Chart.yaml | 4 ++-- charts/lc_classification_step/Chart.yaml | 4 ++-- charts/lightcurve-step/Chart.yaml | 4 ++-- charts/magstats_step/Chart.yaml | 4 ++-- charts/metadata_step/Chart.yaml | 4 ++-- charts/prv_candidates_step/Chart.yaml | 4 ++-- charts/s3_step/Chart.yaml | 4 ++-- charts/scribe/Chart.yaml | 4 ++-- charts/sorting_hat_step/Chart.yaml | 4 ++-- charts/watchlist_step/Chart.yaml | 4 ++-- charts/xmatch_step/Chart.yaml | 4 ++-- correction_step/pyproject.toml | 2 +- early_classification_step/pyproject.toml | 4 +++- feature_step/pyproject.toml | 2 +- lc_classification_step/pyproject.toml | 2 +- lightcurve-step/pyproject.toml | 2 +- magstats_step/pyproject.toml | 2 +- metadata_step/pyproject.toml | 2 +- prv_candidates_step/pyproject.toml | 2 +- s3_step/pyproject.toml | 2 +- scribe/pyproject.toml | 2 +- sorting_hat_step/pyproject.toml | 2 +- watchlist_step/pyproject.toml | 2 +- xmatch_step/pyproject.toml | 2 +- 28 files changed, 44 insertions(+), 42 deletions(-) diff --git a/alert_archiving_step/pyproject.toml b/alert_archiving_step/pyproject.toml index 377768292..68687f14c 100644 --- a/alert_archiving_step/pyproject.toml +++ b/alert_archiving_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "alert-archiving-step" -version = "6.1.1a78" +version = "6.1.1a79" description = "Group alerts and upload to S3 by date" authors = ["ALeRCE"] readme = "README.md" diff --git a/charts/alert_archiving_step/Chart.yaml b/charts/alert_archiving_step/Chart.yaml index be1ac1581..90bef85ec 100644 --- a/charts/alert_archiving_step/Chart.yaml +++ b/charts/alert_archiving_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.1.1a78 +appVersion: 6.1.1a79 description: A Helm chart for Kubernetes name: alert-archive-step type: application -version: 1.2.46 +version: 1.2.47 diff --git a/charts/correction_step/Chart.yaml b/charts/correction_step/Chart.yaml index 67e00482f..f8234c572 100644 --- a/charts/correction_step/Chart.yaml +++ b/charts/correction_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: Correction step chart name: correction-step type: application -version: 1.2.164 +version: 1.2.165 diff --git a/charts/early_classification_step/Chart.yaml b/charts/early_classification_step/Chart.yaml index d4ceb6084..29067f705 100644 --- a/charts/early_classification_step/Chart.yaml +++ b/charts/early_classification_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: A Helm chart for Kubernetes name: early-classifier type: application -version: 1.2.157 +version: 1.2.158 diff --git a/charts/feature_step/Chart.yaml b/charts/feature_step/Chart.yaml index 89eff0ae1..6c99d1e99 100644 --- a/charts/feature_step/Chart.yaml +++ b/charts/feature_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: Step for feature calculation name: feature-step type: application -version: 1.4.162 +version: 1.4.163 diff --git a/charts/lc_classification_step/Chart.yaml b/charts/lc_classification_step/Chart.yaml index ef7e3ec89..05a809aba 100644 --- a/charts/lc_classification_step/Chart.yaml +++ b/charts/lc_classification_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: Lightcurve classifier step name: lc-classifier-step type: application -version: 4.8.158 +version: 4.8.159 diff --git a/charts/lightcurve-step/Chart.yaml b/charts/lightcurve-step/Chart.yaml index 64ed4301b..f01f69d62 100644 --- a/charts/lightcurve-step/Chart.yaml +++ b/charts/lightcurve-step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: Full lightcurve provider step name: lightcurve-step type: application -version: 1.3.163 +version: 1.3.164 diff --git a/charts/magstats_step/Chart.yaml b/charts/magstats_step/Chart.yaml index 7d1eb3a22..bc83d548e 100644 --- a/charts/magstats_step/Chart.yaml +++ b/charts/magstats_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: A Helm chart for Kubernetes name: magstats-step type: application -version: 1.2.163 +version: 1.2.164 diff --git a/charts/metadata_step/Chart.yaml b/charts/metadata_step/Chart.yaml index 321405c0f..61a2e85bf 100644 --- a/charts/metadata_step/Chart.yaml +++ b/charts/metadata_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a49 +appVersion: 6.2.1a50 description: A Helm chart for Kubernetes name: metadata-step type: application -version: 1.0.50 +version: 1.0.51 diff --git a/charts/prv_candidates_step/Chart.yaml b/charts/prv_candidates_step/Chart.yaml index a551dbfe3..11e5ac5a7 100644 --- a/charts/prv_candidates_step/Chart.yaml +++ b/charts/prv_candidates_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: Previous candidates processor step name: prv-candidates type: application -version: 1.3.163 +version: 1.3.164 diff --git a/charts/s3_step/Chart.yaml b/charts/s3_step/Chart.yaml index 1de3281f0..7f33a543f 100644 --- a/charts/s3_step/Chart.yaml +++ b/charts/s3_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: A Helm chart for Kubernetes name: s3-step type: application -version: 1.3.159 \ No newline at end of file +version: 1.3.160 \ No newline at end of file diff --git a/charts/scribe/Chart.yaml b/charts/scribe/Chart.yaml index d8d576924..55f5a84b7 100644 --- a/charts/scribe/Chart.yaml +++ b/charts/scribe/Chart.yaml @@ -15,10 +15,10 @@ type: application # This is the chart version. This version number should be incremented each time you make changes # to the chart and its templates, including the app version. # Versions are expected to follow Semantic Versioning (https://semver.org/) -version: 1.1.162 +version: 1.1.163 # This is the version number of the application being deployed. This version number should be # incremented each time you make changes to the application. Versions are not expected to # follow Semantic Versioning. They should reflect the version the application is using. # It is recommended to use it with quotes. -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 diff --git a/charts/sorting_hat_step/Chart.yaml b/charts/sorting_hat_step/Chart.yaml index 83f4eea9b..5f99a35b0 100644 --- a/charts/sorting_hat_step/Chart.yaml +++ b/charts/sorting_hat_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: Sorting Hat deployment chart name: sorting-hat type: application -version: 2.6.163 +version: 2.6.164 diff --git a/charts/watchlist_step/Chart.yaml b/charts/watchlist_step/Chart.yaml index 0cda8de94..08b1c2e23 100644 --- a/charts/watchlist_step/Chart.yaml +++ b/charts/watchlist_step/Chart.yaml @@ -1,7 +1,7 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: A Helm chart for Kubernetes name: watchlist-step type: application -version: 1.2.153 +version: 1.2.154 diff --git a/charts/xmatch_step/Chart.yaml b/charts/xmatch_step/Chart.yaml index 7f9028863..257d597f9 100644 --- a/charts/xmatch_step/Chart.yaml +++ b/charts/xmatch_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a82 +appVersion: 6.2.1a83 description: A Helm chart for Kubernetes name: xmatch-step type: application -version: 2.3.163 \ No newline at end of file +version: 2.3.164 \ No newline at end of file diff --git a/correction_step/pyproject.toml b/correction_step/pyproject.toml index 9ef8035f1..1104e0c80 100644 --- a/correction_step/pyproject.toml +++ b/correction_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "correction" -version = "6.2.1a82" +version = "6.2.1a83" description = "Correction library for ALeRCE pipeline." authors = ["ALeRCE Broker "] readme = "README.md" diff --git a/early_classification_step/pyproject.toml b/early_classification_step/pyproject.toml index 2669b9b90..3d1b07c59 100644 --- a/early_classification_step/pyproject.toml +++ b/early_classification_step/pyproject.toml @@ -4,7 +4,7 @@ build-backend = "poetry.core.masonry.api" [tool.poetry] name = "early_classification_step" -version = "6.2.1a82" +version = "6.2.1a83" description = "Early Classification Step" authors = [] readme = "README.md" @@ -139,6 +139,7 @@ line-length = 88 + [tool.poetry.group.test.dependencies] @@ -263,6 +264,7 @@ pytest-docker = "^1.0.1" + [tool.poetry.group.model.dependencies] diff --git a/feature_step/pyproject.toml b/feature_step/pyproject.toml index f0f9ff29b..2426851ef 100644 --- a/feature_step/pyproject.toml +++ b/feature_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "feature-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "" authors = [] readme = "README.md" diff --git a/lc_classification_step/pyproject.toml b/lc_classification_step/pyproject.toml index 9e19ab8fb..97670e2b9 100644 --- a/lc_classification_step/pyproject.toml +++ b/lc_classification_step/pyproject.toml @@ -4,7 +4,7 @@ build-backend = "poetry.core.masonry.api" [tool.poetry] name = "lc_classification_step" -version = "6.2.1a82" +version = "6.2.1a83" description = "LC Classification Step" authors = [] readme = "README.md" diff --git a/lightcurve-step/pyproject.toml b/lightcurve-step/pyproject.toml index 3203964e7..af9c2ce4e 100644 --- a/lightcurve-step/pyproject.toml +++ b/lightcurve-step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "lightcurve-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "Lightcurve Step" authors = [] readme = "README.md" diff --git a/magstats_step/pyproject.toml b/magstats_step/pyproject.toml index de834e9c3..b9486c0ea 100644 --- a/magstats_step/pyproject.toml +++ b/magstats_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "magstats-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "" authors = ["ASHuenchuleo "] readme = "README.md" diff --git a/metadata_step/pyproject.toml b/metadata_step/pyproject.toml index 052c2c17a..6c406ef0b 100644 --- a/metadata_step/pyproject.toml +++ b/metadata_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "metadata-step" -version = "6.2.1a49" +version = "6.2.1a50" description = "" authors = ["Pedro Gallardo "] readme = "README.md" diff --git a/prv_candidates_step/pyproject.toml b/prv_candidates_step/pyproject.toml index d7343c4ad..58e6dec62 100644 --- a/prv_candidates_step/pyproject.toml +++ b/prv_candidates_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "prv-candidates-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "Previous Detections Step" authors = [] readme = "README.md" diff --git a/s3_step/pyproject.toml b/s3_step/pyproject.toml index dc933f406..4be7500df 100644 --- a/s3_step/pyproject.toml +++ b/s3_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "s3-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "S3 step" authors = [] readme = "README.md" diff --git a/scribe/pyproject.toml b/scribe/pyproject.toml index ab5aaeab4..e333026b9 100644 --- a/scribe/pyproject.toml +++ b/scribe/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "scribe" -version = "6.2.1a82" +version = "6.2.1a83" description = "Mongo scribe" authors = [] readme = "README.md" diff --git a/sorting_hat_step/pyproject.toml b/sorting_hat_step/pyproject.toml index 4b30d5972..e4a654de4 100644 --- a/sorting_hat_step/pyproject.toml +++ b/sorting_hat_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "sorting-hat-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "Sorting hat step" authors = [] readme = "README.md" diff --git a/watchlist_step/pyproject.toml b/watchlist_step/pyproject.toml index a9d8d350c..0889926e8 100644 --- a/watchlist_step/pyproject.toml +++ b/watchlist_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "watchlist-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "Watchlist Step" authors = [] readme = "README.md" diff --git a/xmatch_step/pyproject.toml b/xmatch_step/pyproject.toml index f175cf10e..a8e6379a4 100644 --- a/xmatch_step/pyproject.toml +++ b/xmatch_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "xmatch-step" -version = "6.2.1a82" +version = "6.2.1a83" description = "xmatch step" authors = [] readme = "README.md"