Merge branch 'main' into refactor/schemaless_consumer_use_path

alercebroker · Nov 22, 2023 · 47cd524 · 47cd524
2 parents 8bece78 + 95f8811
commit 47cd524
Show file tree

Hide file tree

Showing 30 changed files with 36 additions and 33 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
+version: 1.3.179
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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 <[email protected]>"]
 readme = "README.md"

diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "magstats-step"
-version = "6.2.1a101"
+version = "6.2.1a102"
 description = ""
 authors = ["ASHuenchuleo <[email protected]>"]
 readme = "README.md"

diff --git 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 <[email protected]>"]
 readme = "README.md"

diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "xmatch-step"
-version = "6.2.1a101"
+version = "6.2.1a102"
 description = "xmatch step"
 authors = []
 readme = "README.md"