fix config

keboola · Nov 29, 2024 · 7326160 · 7326160
1 parent 2384aba
commit 7326160
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/component.py b/src/component.py
@@ -52,8 +52,8 @@ def run(self, debug=False):
 
         self.params = Configuration(**self.configuration.parameters)
 
-        self.params.group_id = f"kbc-proj-{self.environment_variables.project_id}"
-        self.params.client_id = f"kbc-config-{self.environment_variables.config_row_id}"
+        self.params.group_id = f"kbc-proj-{self.environment_variables.project_id}" or "kbc-proj-0"
+        self.params.client_id = f"kbc-config-{self.environment_variables.config_row_id}" or "kbc-config-0"
 
         # Generating a string out of the list
         servers = ",".join(self.params.servers)

diff --git a/src/configuration.py b/src/configuration.py
@@ -12,6 +12,9 @@ class Units(str, Enum):
 
 class Configuration(BaseModel):
     servers: list[str] = Field(default=None)
+    group_id: str = Field(default=None)
+    client_id: str = Field(default=None)
+
     topics: list[str] = Field(default=None)
 
     security_protocol: str = Field(default=None)