Project

Profile

Help

Issue #6270

closed

Cannot dispatch a task from within a task

Added by bmbouter about 4 years ago. Updated about 4 years ago.

Status:
CLOSED - NOTABUG
Priority:
Normal
Assignee:
Category:
-
Sprint/Milestone:
-
Start date:
Due date:
Estimated time:
Severity:
2. Medium
Version:
Platform Release:
OS:
Triaged:
Yes
Groomed:
No
Sprint Candidate:
No
Tags:
Sprint:
Sprint 67
Quarter:

Description

When dispatching a task within a task you'll get this error:

pulp: rq.worker:ERROR: TypeError: Task() got an unexpected keyword argument 'parent'
Traceback (most recent call last):
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/rq/worker.py", line 884, in perform_job
    rv = job.perform()
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/rq/job.py", line 664, in perform
    self._result = self._execute()
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/rq/job.py", line 670, in _execute
    return self.func(*self.args, **self.kwargs)
  File "/home/vagrant/devel/pulp_ansible/pulp_ansible/app/tasks/test_tasks.py", line 87, in promote_content
    enqueue_with_reservation(add_content_to_repositories, locks, args=task_args)
  File "/home/vagrant/devel/pulpcore/pulpcore/tasking/tasks.py", line 201, in enqueue_with_reservation
    name=f'{func.__module__}.{func.__name__}', **parent_kwarg)
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/django/db/models/manager.py", line 82, in manager_method
    return getattr(self.get_queryset(), name)(*args, **kwargs)
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/django/db/models/query.py", line 420, in create
    obj = self.model(**kwargs)
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/django/db/models/base.py", line 501, in __init__
    raise TypeError("%s() got an unexpected keyword argument '%s'" % (cls.__name__, kwarg))
TypeError: Task() got an unexpected keyword argument 'parent'
Traceback (most recent call last):
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/rq/worker.py", line 884, in perform_job
    rv = job.perform()
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/rq/job.py", line 664, in perform
    self._result = self._execute()
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/rq/job.py", line 670, in _execute
    return self.func(*self.args, **self.kwargs)
  File "/home/vagrant/devel/pulp_ansible/pulp_ansible/app/tasks/test_tasks.py", line 87, in promote_content
    enqueue_with_reservation(add_content_to_repositories, locks, args=task_args)
  File "/home/vagrant/devel/pulpcore/pulpcore/tasking/tasks.py", line 201, in enqueue_with_reservation
    name=f'{func.__module__}.{func.__name__}', **parent_kwarg)
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/django/db/models/manager.py", line 82, in manager_method
    return getattr(self.get_queryset(), name)(*args, **kwargs)
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/django/db/models/query.py", line 420, in create
    obj = self.model(**kwargs)
  File "/usr/local/lib/pulp/lib64/python3.7/site-packages/django/db/models/base.py", line 501, in __init__
    raise TypeError("%s() got an unexpected keyword argument '%s'" % (cls.__name__, kwarg))
TypeError: Task() got an unexpected keyword argument 'parent'
Actions #1

Updated by fao89 about 4 years ago

  • Triaged changed from No to Yes
  • Sprint set to Sprint 67
Actions #2

Updated by bmbouter about 4 years ago

  • Status changed from NEW to ASSIGNED
  • Assignee set to bmbouter

This is blocking the pulp_ansible scale testing.

Actions #3

Updated by bmbouter about 4 years ago

  • Status changed from ASSIGNED to POST

Added by bmbouter about 4 years ago

Revision 18cec045 | View on GitHub

Allows tasks to dispatch tasks

https://pulp.plan.io/issues/6270 closes #6270

Actions #4

Updated by bmbouter about 4 years ago

  • Status changed from POST to MODIFIED
Actions #5

Updated by daviddavis about 4 years ago

  • Status changed from MODIFIED to CLOSED - NOTABUG

This change was superseded by https://pulp.plan.io/issues/6282

Also available in: Atom PDF