Unanswered
Hi,
I Am Trying To Using Clearml Agent Version 0.16 ("Trains_Agent"), And I Always Get A Silent Exit After Starting Task Execution:
Hi SuccessfulKoala55 , thanks for the quick reply!
This is a stand-alone code, that creates a task, clones it, and enqueues the cloned task:
` def enqueue_task(trains_prms, task_name, task_type):
# Connect to trains
task = Task.init("OMD", task_name='Temp controller for ' + task_name, task_type=task_type) # , task_type=Task.TaskTypes.controller
# Select queue
trains_queue = "cpu_queue"
# Connect parameters
assert "is_controller_run" not in trains_prms
trains_prms["is_controller_run"] = True
trains_prms = task.connect(trains_prms)
print("Connected to trains")
if trains_prms["is_controller_run"]:
# Controller work
task.close()
# Get a reference to the task to pipe to.
next_task = Task.get_task(task_id=task.id)
# Clone the task to pipe to. This creates a task with status Draft whose parameters can be modified.
cloned_task = Task.clone(source_task=next_task, name=task_name)
# Get the original parameters of the Task, modify the value of one parameter,
# and set the parameters in the next Task
cloned_task_parameters = cloned_task.get_parameters()
cloned_task_parameters["is_controller_run"] = False
cloned_task.set_parameters(cloned_task_parameters)
# Enqueue the Task for execution. The enqueued Task must already exist in the clearml platform
print('Enqueue task: ' + task_name)
Task.enqueue(cloned_task.id, queue_name=trains_queue)
print('Enqueued task: ' + task_name)
is_controller_run = True
# Controller is finished
return is_controller_run, trains_prms, -1
# Not the controller
return trains_prms["is_controller_run"], trains_prms, task `
146 Views
0
Answers
3 years ago
one year ago