worker.py

from MinnieTask import (
    MinnieNucMergeTask,
    MinniePerformNucMergeTask,
    quantify_soma_region,
    execute_split, 
    readjust_nuclei
)
from taskqueue import TaskQueue
import sys


queue = sys.argv[1]
timeout = int(sys.argv[2])
with TaskQueue(qurl=queue, n_threads=0) as tq:
    tq.poll(lease_seconds=timeout)