Skip to content

Commit

Permalink
fix error in task manager
Browse files Browse the repository at this point in the history
  • Loading branch information
jefer94 committed Sep 23, 2023
1 parent acde1fb commit 4ec4916
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions breathecode/commons/tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -122,10 +122,12 @@ def mark_task_as_pending(task_manager_id, *, attempts=0, force=False, last_run=N

module = importlib.import_module(x.task_module)
function = getattr(module, x.task_name)
function.delay(*x.arguments['args'],
**x.arguments['kwargs'],
page=x.current_page + 1,
total_pages=x.total_pages,
task_manager_id=task_manager_id)
function.delay(
*x.arguments['args'], **{
**x.arguments['kwargs'],
'page': x.current_page + 1,
'total_pages': x.total_pages,
'task_manager_id': task_manager_id,
})

logger.info(f'TaskManager {task_manager_id} is PENDING')

0 comments on commit 4ec4916

Please sign in to comment.