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)