diff --git a/trustgraph-base/trustgraph/base/pubsub.py b/trustgraph-base/trustgraph/base/pubsub.py
index b9f233d4..90b65d5b 100644
--- a/trustgraph-base/trustgraph/base/pubsub.py
+++ b/trustgraph-base/trustgraph/base/pubsub.py
@@ -73,8 +73,7 @@ class PulsarClient:
 
         parser.add_argument(
             '-l', '--log-level',
-            type=LogLevel,
-            default=LogLevel.INFO,
-            choices=list(LogLevel),
-            help=f'Output queue (default: info)'
+            default='INFO',
+            choices=['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL'],
+            help=f'Log level (default: INFO)'
         )
diff --git a/trustgraph-flow/trustgraph/gateway/service.py b/trustgraph-flow/trustgraph/gateway/service.py
index ee66b9d3..1e2fdb23 100755
--- a/trustgraph-flow/trustgraph/gateway/service.py
+++ b/trustgraph-flow/trustgraph/gateway/service.py
@@ -162,10 +162,9 @@ def run():
 
     parser.add_argument(
         '-l', '--log-level',
-        type=LogLevel,
-        default=LogLevel.INFO,
-        choices=list(LogLevel),
-        help=f'Output queue (default: info)'
+        default='INFO',
+        choices=['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL'],
+        help=f'Log level (default: INFO)'
     )
 
     parser.add_argument(
diff --git a/trustgraph-flow/trustgraph/processing/processing.py b/trustgraph-flow/trustgraph/processing/processing.py
index 8ee62cdd..4ad5e057 100644
--- a/trustgraph-flow/trustgraph/processing/processing.py
+++ b/trustgraph-flow/trustgraph/processing/processing.py
@@ -19,8 +19,7 @@ def fn(module_name, class_name, params, w):
 
     logger.info(f"Starting {module_name}...")
 
-    if "log_level" in params:
-        params["log_level"] = LogLevel(params["log_level"])
+    # log_level is already a string, no conversion needed
 
     while True:
 
@@ -147,10 +146,9 @@ def run():
 
     parser.add_argument(
         '-l', '--log-level',
-        type=LogLevel,
-        default=LogLevel.INFO,
-        choices=list(LogLevel),
-        help=f'Output queue (default: info)'
+        default='INFO',
+        choices=['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL'],
+        help=f'Log level (default: INFO)'
     )
 
     parser.add_argument(