From 14cce1ef09ed96ebb16cf9b785494ea4a08df096 Mon Sep 17 00:00:00 2001
From: Steve Nyemba <steve@the-phi.com>
Date: Wed, 4 Mar 2020 13:40:26 -0600
Subject: [PATCH] bug fix with worker ...

---
 pipeline.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pipeline.py b/pipeline.py
index fd5a28e..8c8a7d7 100644
--- a/pipeline.py
+++ b/pipeline.py
@@ -233,6 +233,7 @@ if __name__ == '__main__' :
 	args = dict(args,**SYS_ARGS)
 	args['max_rows'] = int(args['max_rows']) 	if 'max_rows' in args else 3
 	args['part_size']= int(args['part_size']) 	if 'part_size' in args else 3
+	
 
 	#
 	# @TODO:
@@ -265,6 +266,7 @@ if __name__ == '__main__' :
 	elif 'listen' in args :
 		#
 		# This will start a worker just in case to listen to a queue
+		SYS_ARGS = dict(args)	#-- things get lost in context
 		if 'read' in SYS_ARGS :
 			QUEUE_TYPE = 'queue.QueueReader'
 			pointer = lambda qreader: qreader.read(1)