We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 29d0e33 commit bcbbb0cCopy full SHA for bcbbb0c
embark/workers/tasks.py
@@ -602,10 +602,10 @@ def worker_soft_reset_task(worker_id, only_reset=False):
602
"""
603
ssh_client = None
604
try:
605
+ worker = Worker.objects.get(id=worker_id)
606
if not only_reset:
607
# Remove the worker from the orchestrator
608
orchestrator = get_orchestrator()
- worker = Worker.objects.get(id=worker_id)
609
orchestrator.remove_worker(worker, check=False)
610
611
# Reassign the analysis running on the worker
0 commit comments