fix errors in seek when flow is not active

faust-streaming · Feb 4, 2022 · c3fadfb · c3fadfb
1 parent 0b64ab9
commit c3fadfb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/faust/types/models.py b/faust/types/models.py
@@ -57,6 +57,7 @@ def __init_subclass__(
     class _UsingKwargsInNew(_InitSubclassCheck, ident=909):
         ...
 
+
 except TypeError:
     abc_compatible_with_init_subclass = False
 else:

diff --git a/faust/utils/json.py b/faust/utils/json.py
@@ -179,6 +179,7 @@ def loads(s: str, json_loads: Callable = orjson.loads, **kwargs: Any) -> Any:
         """Deserialize json string."""
         return json_loads(s)
 
+
 else:
 
     def dumps(
-Original file line number
+Diff line change
@@ Expand Up / @@ -57,6 +57,7 @@ def __init_subclass__( @@
         class _UsingKwargsInNew(_InitSubclassCheck, ident=909):
             ...
     except TypeError:
         abc_compatible_with_init_subclass = False
     else:
@@ Expand Down @@