bug fixes for valmi-connector-lib

git-tags.py

@@ -1,26 +1,26 @@
 import os
 connectors = {
-    "destination-webhook": "0.1.14",
-    "destination-stripe": "0.1.8",
-    "destination-slack": "0.1.8",
-    "destination-hubspot": "0.1.8",
-    "destination-google-sheets": "0.1.8",
-    "destination-google-ads": "0.1.8",
-    "destination-gong": "0.1.8",
-    "destination-facebook-ads": "0.1.8",
-    "destination-customer-io": "0.1.8",
-    "destination-android-push-notifications": "0.1.9",
+    "destination-webhook": "0.1.17",
+    "destination-stripe": "0.1.9",
+    "destination-slack": "0.1.9",
+    "destination-hubspot": "0.1.9",
+    "destination-google-sheets": "0.1.9",
+    "destination-google-ads": "0.1.9",
+    "destination-gong": "0.1.9",
+    "destination-facebook-ads": "0.1.9",
+    "destination-customer-io": "0.1.9",
+    "destination-android-push-notifications": "0.1.10",
 
-    "source-redshift": "0.1.12",
-    "source-snowflake": "0.1.12",
-    "source-postgres": "0.1.12"
+    "source-redshift": "0.1.13",
+    "source-snowflake": "0.1.13",
+    "source-postgres": "0.1.13"
 }
 
-valmi_core = "0.1.16"
+valmi_core = "0.1.18"
 
-valmi_app_backend = "0.1.16"
+valmi_app_backend = "0.1.17"
 
-valmi_app = "0.1.14"
+valmi_app = "0.1.15"
 
 def tag_and_push(tag_name, message):
     os.system("git tag -a %s -m '%s'" % (tag_name, message))

packages/valmi-connector-lib/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "valmi-connector-lib"
-version = "0.1.100"
+version = "0.1.101"
 description = ""
 authors = ["Rajashekar Varkala <raj@valmi.io>"]
 readme = "README.md"

packages/valmi-connector-lib/valmi_connector_lib/common/samples.py

@@ -55,7 +55,7 @@ def __init__(self, store_config_str, flush_policy, sync_id, run_id, connector, m
         self.run_id = run_id
         self.connector = connector
         self.metric_type = metric_type
-        self.num_samples_per_code = os.environ.get("NUM_SAMPLES_PER_CODE", 10)
+        self.num_samples_per_code = int(os.environ.get("NUM_SAMPLES_PER_CODE", 10))
         self.sample_counter: dict[str, int] = defaultdict(lambda: 0)
 
     def reset(self):

src/observability.py

@@ -32,7 +32,7 @@ def observable_counter_func(options: CallbackOptions) -> Iterable[Observation]:
 
 
 def setup_observability(app: FastAPI):
-    if os.environ.get('OTEL_FASTAPI_INSTRUMENT', False):
+    if os.environ.get('OTEL_FASTAPI_INSTRUMENT', False) is True:
         trace.set_tracer_provider(TracerProvider())
         otlp_exporter = OTLPSpanExporter()
         span_processor = BatchSpanProcessor(otlp_exporter)