premier commit

adimian · Oct 4, 2019 · 326beee · 326beee
1 parent 805449c
commit 326beee
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/kirby/api/ext/topic.py b/kirby/api/ext/topic.py
@@ -2,6 +2,7 @@
 import logging
 import msgpack
 import tenacity
+import uuid
 
 from collections import namedtuple
 from contextlib import contextmanager
@@ -338,7 +339,7 @@ def __init__(
         else:
             self.topic_config = TopicConfig(
                 name=topic_name,
-                group_id=ctx.PACKAGE_NAME if not group_id else group_id,
+                group_id=str(uuid.uuid4()) if not group_id else group_id,
                 use_tls=use_tls,
                 raw_records=raw_records,
             )

diff --git a/kirby/supervisor/executor/__init__.py b/kirby/supervisor/executor/__init__.py
@@ -18,6 +18,7 @@
 
 
 def convert_variables(data):
+
     return {variable["key"]: variable["value"] for variable in data}