Skip to content

Commit 034ea56

Browse files
committed
Random cleanups
Signed-off-by: Yves Bastide <yves@botify.com>
1 parent 11696ed commit 034ea56

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

simpleflow/command.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -407,7 +407,7 @@ def start_worker(unused_workflow, domain, task_list, log_level, nb_processes, he
407407
)
408408

409409

410-
def get_task_list(workflow_id=''):
410+
def create_unique_task_list(workflow_id=''):
411411
task_list_id = '-' + uuid4().hex
412412
overflow = 256 - len(task_list_id) - len(workflow_id)
413413
if overflow < 0:
@@ -522,7 +522,7 @@ def standalone(context,
522522
else:
523523
previous_history = None
524524

525-
task_list = get_task_list(workflow_id)
525+
task_list = create_unique_task_list(workflow_id)
526526
logger.info('using task list {}'.format(task_list))
527527
decider_proc = multiprocessing.Process(
528528
target=decider.command.start,

simpleflow/swf/process/worker/base.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ class ActivityPoller(Poller, swf.actors.ActivityWorker):
3333
Polls an activity and handles it in the worker.
3434
3535
"""
36-
def __init__(self, domain, task_list, heartbeat=60, *args, **kwargs):
36+
def __init__(self, domain, task_list, heartbeat=60):
3737
"""
3838
3939
:param domain:
@@ -42,10 +42,6 @@ def __init__(self, domain, task_list, heartbeat=60, *args, **kwargs):
4242
:type task_list:
4343
:param heartbeat:
4444
:type heartbeat:
45-
:param args:
46-
:type args:
47-
:param kwargs:
48-
:type kwargs:
4945
"""
5046
self.nb_retries = 3
5147
# heartbeat=0 is a special value to disable heartbeating. We want to

0 commit comments

Comments
 (0)