formatting

datayoga-io · Oct 31, 2023 · b90950e · b90950e
1 parent b08a511
commit b90950e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/core/src/datayoga_core/blocks/redis/read_stream/block.py b/core/src/datayoga_core/blocks/redis/read_stream/block.py
@@ -18,7 +18,6 @@ def init(self, context: Optional[Context] = None):
         connection = get_connection_details(self.properties.get("connection"), context)
         self.redis_client = redis_utils.get_client(connection)
 
-
         self.stream = self.properties["stream_name"]
         self.snapshot = self.properties.get("snapshot", False)
         self.consumer_group = f'datayoga_job_{context.properties.get("job_name", "") if context else ""}'

diff --git a/core/src/datayoga_core/blocks/redis/utils.py b/core/src/datayoga_core/blocks/redis/utils.py
@@ -25,8 +25,8 @@ def get_client(connection: Dict[str, Any]) -> Redis:
     Raises:
         ValueError: If connection to Redis fails.
     """
-    host=connection["host"]
-    port=connection["port"]
+    host = connection["host"]
+    port = connection["port"]
     key = connection.get("key")
     key_password = connection.get("key_password")
     cert = connection.get("cert")