|
|
|
@ -234,6 +234,7 @@ if __name__ == '__main__' :
|
|
|
|
args['max_rows'] = int(args['max_rows']) if 'max_rows' in args else 3
|
|
|
|
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
|
|
|
|
args['part_size']= int(args['part_size']) if 'part_size' in args else 3
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#
|
|
|
|
#
|
|
|
|
# @TODO:
|
|
|
|
# @TODO:
|
|
|
|
# Log what was initiated so we have context of this processing ...
|
|
|
|
# Log what was initiated so we have context of this processing ...
|
|
|
|
@ -265,6 +266,7 @@ if __name__ == '__main__' :
|
|
|
|
elif 'listen' in args :
|
|
|
|
elif 'listen' in args :
|
|
|
|
#
|
|
|
|
#
|
|
|
|
# This will start a worker just in case to listen to a queue
|
|
|
|
# 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 :
|
|
|
|
if 'read' in SYS_ARGS :
|
|
|
|
QUEUE_TYPE = 'queue.QueueReader'
|
|
|
|
QUEUE_TYPE = 'queue.QueueReader'
|
|
|
|
pointer = lambda qreader: qreader.read(1)
|
|
|
|
pointer = lambda qreader: qreader.read(1)
|
|
|
|
|
