From b42e32e28a777f4bbb092fcc14dcff87c1e6a199 Mon Sep 17 00:00:00 2001
From: Rajashekar Varkala <raj@mywavia.com>
Date: Wed, 13 Sep 2023 23:18:09 +0530
Subject: [PATCH] bug fixes for valmi-connector-lib

---
 git-tags.py                                   | 32 +++++++++----------
 packages/valmi-connector-lib/pyproject.toml   |  2 +-
 .../valmi_connector_lib/common/samples.py     |  2 +-
 src/observability.py                          |  2 +-
 valmi-app-backend                             |  2 +-
 5 files changed, 20 insertions(+), 20 deletions(-)

diff --git a/git-tags.py b/git-tags.py
index cb67c97..b996b83 100755
--- a/git-tags.py
+++ b/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))
diff --git a/packages/valmi-connector-lib/pyproject.toml b/packages/valmi-connector-lib/pyproject.toml
index 02ecd7e..4d51aa5 100644
--- a/packages/valmi-connector-lib/pyproject.toml
+++ b/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"
diff --git a/packages/valmi-connector-lib/valmi_connector_lib/common/samples.py b/packages/valmi-connector-lib/valmi_connector_lib/common/samples.py
index 6b44f9a..a5fd5b4 100644
--- a/packages/valmi-connector-lib/valmi_connector_lib/common/samples.py
+++ b/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):
diff --git a/src/observability.py b/src/observability.py
index de7d40a..ab595e0 100644
--- a/src/observability.py
+++ b/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)
diff --git a/valmi-app-backend b/valmi-app-backend
index fbd709c..371e27f 160000
--- a/valmi-app-backend
+++ b/valmi-app-backend
@@ -1 +1 @@
-Subproject commit fbd709c3ca317309600bb01619e1ace93bb0f7f6
+Subproject commit 371e27fcaf11f827ed83e12df8dbe704352a69e2