Fix cli bug using config schema path.

Menziess · Jul 11, 2023 · 8f4534f · 8f4534f
1 parent e866073
commit 8f4534f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/snapstream/__main__.py b/snapstream/__main__.py
@@ -154,7 +154,7 @@ def inspect_topic(entry: dict, args: Namespace):
 
     start_time = dt.now(tz=timezone.utc)
     schema_path = args.schema or entry.get('schema_path')
-    schema = AvroCodec(args.schema) if schema_path else None
+    schema = AvroCodec(schema_path) if schema_path else None
     key_filter = curry(regex_filter)(args.key_filter)
     val_filter = curry(regex_filter)(args.val_filter)