diff --git a/alert_archiving_step/pyproject.toml b/alert_archiving_step/pyproject.toml index 81a3fe867..3f4487215 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.1a97" +version = "6.1.1a98" 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 b7f221083..072588b4b 100644 --- a/charts/alert_archiving_step/Chart.yaml +++ b/charts/alert_archiving_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.1.1a97 +appVersion: 6.1.1a98 description: A Helm chart for Kubernetes name: alert-archive-step type: application -version: 1.2.65 +version: 1.2.66 diff --git a/charts/correction_step/Chart.yaml b/charts/correction_step/Chart.yaml index eeced8e48..fc770133c 100644 --- a/charts/correction_step/Chart.yaml +++ b/charts/correction_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: Correction step chart name: correction-step type: application diff --git a/charts/early_classification_step/Chart.yaml b/charts/early_classification_step/Chart.yaml index 658446a8b..af3bcc848 100644 --- a/charts/early_classification_step/Chart.yaml +++ b/charts/early_classification_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: A Helm chart for Kubernetes name: early-classifier type: application -version: 1.2.176 +version: 1.2.177 diff --git a/charts/feature_step/Chart.yaml b/charts/feature_step/Chart.yaml index 6d5961261..24c664beb 100644 --- a/charts/feature_step/Chart.yaml +++ b/charts/feature_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: Step for feature calculation name: feature-step type: application diff --git a/charts/lc_classification_step/Chart.yaml b/charts/lc_classification_step/Chart.yaml index f14a5ec98..3c1eda0d2 100644 --- a/charts/lc_classification_step/Chart.yaml +++ b/charts/lc_classification_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: Lightcurve classifier step name: lc-classifier-step type: application diff --git a/charts/lightcurve-step/Chart.yaml b/charts/lightcurve-step/Chart.yaml index 59ea7b789..0c0207baa 100644 --- a/charts/lightcurve-step/Chart.yaml +++ b/charts/lightcurve-step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: Full lightcurve provider step name: lightcurve-step type: application diff --git a/charts/magstats_step/Chart.yaml b/charts/magstats_step/Chart.yaml index c1a941079..9fa069a9b 100644 --- a/charts/magstats_step/Chart.yaml +++ b/charts/magstats_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: A Helm chart for Kubernetes name: magstats-step type: application diff --git a/charts/metadata_step/Chart.yaml b/charts/metadata_step/Chart.yaml index 4c8cf355c..3b1867af9 100644 --- a/charts/metadata_step/Chart.yaml +++ b/charts/metadata_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a68 +appVersion: 6.2.1a69 description: A Helm chart for Kubernetes name: metadata-step type: application diff --git a/charts/prv_candidates_step/Chart.yaml b/charts/prv_candidates_step/Chart.yaml index d8c3ac704..b286a023f 100644 --- a/charts/prv_candidates_step/Chart.yaml +++ b/charts/prv_candidates_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: Previous candidates processor step name: prv-candidates type: application diff --git a/charts/s3_step/Chart.yaml b/charts/s3_step/Chart.yaml index 2a93757ce..4ba5b076b 100644 --- a/charts/s3_step/Chart.yaml +++ b/charts/s3_step/Chart.yaml @@ -1,6 +1,6 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: A Helm chart for Kubernetes name: s3-step type: application -version: 1.3.178 \ No newline at end of file +version: 1.3.179 \ No newline at end of file diff --git a/charts/scribe/Chart.yaml b/charts/scribe/Chart.yaml index cfd127fd8..a65cdc2fd 100644 --- a/charts/scribe/Chart.yaml +++ b/charts/scribe/Chart.yaml @@ -21,4 +21,4 @@ version: 2.0.0 # 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.1a101 +appVersion: 6.2.1a102 diff --git a/charts/sorting_hat_step/Chart.yaml b/charts/sorting_hat_step/Chart.yaml index 2e9cd2239..c6805d42a 100644 --- a/charts/sorting_hat_step/Chart.yaml +++ b/charts/sorting_hat_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: Sorting Hat deployment chart name: sorting-hat type: application diff --git a/charts/watchlist_step/Chart.yaml b/charts/watchlist_step/Chart.yaml index d19aa4d87..7e559ba11 100644 --- a/charts/watchlist_step/Chart.yaml +++ b/charts/watchlist_step/Chart.yaml @@ -1,7 +1,7 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: A Helm chart for Kubernetes name: watchlist-step type: application -version: 1.2.172 +version: 1.2.173 diff --git a/charts/xmatch_step/Chart.yaml b/charts/xmatch_step/Chart.yaml index c84791124..66c35e292 100644 --- a/charts/xmatch_step/Chart.yaml +++ b/charts/xmatch_step/Chart.yaml @@ -1,5 +1,5 @@ apiVersion: v2 -appVersion: 6.2.1a101 +appVersion: 6.2.1a102 description: A Helm chart for Kubernetes name: xmatch-step type: application diff --git a/ci/helm_values/production/templates/prv_candidates_step_helm_values_elasticc.tftpl b/ci/helm_values/production/templates/prv_candidates_step_helm_values_elasticc.tftpl index 63891b3b7..4a172939f 100644 --- a/ci/helm_values/production/templates/prv_candidates_step_helm_values_elasticc.tftpl +++ b/ci/helm_values/production/templates/prv_candidates_step_helm_values_elasticc.tftpl @@ -24,6 +24,7 @@ configmap: producerTopic: prv-candidates_elasticc scribeServer: ${kafka_server} scribeTopic: w_non_detections_elasticc + useProfiling: true extraEnvVariables: - name: METRICS_SOURCE value: 'prv-candidates-elasticc' diff --git a/correction_step/pyproject.toml b/correction_step/pyproject.toml index 6d688746a..660f5047a 100644 --- a/correction_step/pyproject.toml +++ b/correction_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "correction" -version = "6.2.1a101" +version = "6.2.1a102" 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 8a74085fb..20bd4127a 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.1a101" +version = "6.2.1a102" description = "Early Classification Step" authors = [] readme = "README.md" @@ -158,6 +158,7 @@ line-length = 88 + [tool.poetry.group.test.dependencies] @@ -301,6 +302,7 @@ pytest-docker = "^1.0.1" + [tool.poetry.group.model.dependencies] diff --git a/feature_step/pyproject.toml b/feature_step/pyproject.toml index c4f1547e9..73d31be75 100644 --- a/feature_step/pyproject.toml +++ b/feature_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "feature-step" -version = "6.2.1a101" +version = "6.2.1a102" description = "" authors = [] readme = "README.md" diff --git a/lc_classification_step/pyproject.toml b/lc_classification_step/pyproject.toml index ffc3df304..ab3508676 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.1a101" +version = "6.2.1a102" description = "LC Classification Step" authors = [] readme = "README.md" diff --git a/libs/apf/apf/consumers/kafka.py b/libs/apf/apf/consumers/kafka.py index 8105edeb9..1b5a05647 100644 --- a/libs/apf/apf/consumers/kafka.py +++ b/libs/apf/apf/consumers/kafka.py @@ -250,7 +250,7 @@ def consume(self, num_messages=1, timeout=60): else: if self.config.get("offsets"): end = self.config["offsets"].get( - "end", datetime.datetime.now().timestamp() + 1 + "end", (datetime.datetime.now().timestamp() + 1) * 1000 ) if message.timestamp()[1] >= end: self.logger.info( diff --git a/lightcurve-step/pyproject.toml b/lightcurve-step/pyproject.toml index a2bd46df2..8800b8d88 100644 --- a/lightcurve-step/pyproject.toml +++ b/lightcurve-step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "lightcurve-step" -version = "6.2.1a101" +version = "6.2.1a102" description = "Lightcurve Step" authors = [] readme = "README.md" diff --git a/magstats_step/pyproject.toml b/magstats_step/pyproject.toml index e64c1ae5e..79be0bfa2 100644 --- a/magstats_step/pyproject.toml +++ b/magstats_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "magstats-step" -version = "6.2.1a101" +version = "6.2.1a102" description = "" authors = ["ASHuenchuleo "] readme = "README.md" diff --git a/metadata_step/pyproject.toml b/metadata_step/pyproject.toml index fc25e6bb1..9d4391814 100644 --- a/metadata_step/pyproject.toml +++ b/metadata_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "metadata-step" -version = "6.2.1a68" +version = "6.2.1a69" description = "" authors = ["Pedro Gallardo "] readme = "README.md" diff --git a/prv_candidates_step/pyproject.toml b/prv_candidates_step/pyproject.toml index da1013aa2..d521168c6 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.1a101" +version = "6.2.1a102" description = "Previous Detections Step" authors = [] readme = "README.md" diff --git a/s3_step/pyproject.toml b/s3_step/pyproject.toml index 21cad6792..b365884ff 100644 --- a/s3_step/pyproject.toml +++ b/s3_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "s3-step" -version = "6.2.1a101" +version = "6.2.1a102" description = "S3 step" authors = [] readme = "README.md" diff --git a/scribe/pyproject.toml b/scribe/pyproject.toml index 1946c9307..639b615f8 100644 --- a/scribe/pyproject.toml +++ b/scribe/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "scribe" -version = "6.2.1a101" +version = "6.2.1a102" description = "Mongo scribe" authors = [] readme = "README.md" diff --git a/sorting_hat_step/pyproject.toml b/sorting_hat_step/pyproject.toml index dc08ba0fb..6ece1736a 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.1a101" +version = "6.2.1a102" description = "Sorting hat step" authors = [] readme = "README.md" diff --git a/watchlist_step/pyproject.toml b/watchlist_step/pyproject.toml index 690ba9ab0..6562fddc3 100644 --- a/watchlist_step/pyproject.toml +++ b/watchlist_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "watchlist-step" -version = "6.2.1a101" +version = "6.2.1a102" description = "Watchlist Step" authors = [] readme = "README.md" diff --git a/xmatch_step/pyproject.toml b/xmatch_step/pyproject.toml index 18c313806..49c833248 100644 --- a/xmatch_step/pyproject.toml +++ b/xmatch_step/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "xmatch-step" -version = "6.2.1a101" +version = "6.2.1a102" description = "xmatch step" authors = [] readme = "README.md"