Unanswered
Hi All.
I'M Setting Up An Model Export Script That Will Export Trained Models For Edge Deployment. I Initially Thought About Setting It Up As A Trigger Scheduler, And To Have It Trigger On Tags On A Published Model, But As Time Goes By The Trigger Schedul
hi i have similar case, but can we scheduled new task here?
def trigger_task_func(task_id):
print("trigger running...")
try:
previous_task = Task.get_task(task_id=task_id)
print(previous_task.artifacts)
try:
fp = previous_task.artifacts['latest_condition'].get_local_copy()
params = open_json(fp)
last_index = params.get('last_index')
day_n = params.get('iteration')
print("Success Fetching", params)
except Exception as e:
print("Failed Fetching", e)
last_index = 100
day_n = 10
print("Create Scheduler New")
scheduler = TaskScheduler()
scheduler.add_task(
target_project='Playground/xxx',
name=f"xxx Iteration-{day_n}",
queue='cpu-xxx-preprod-xxx',
schedule_task_id=task_id,
hours=2,
recurring=False,
execute_immediately=False,
task_parameters={
"last_index": last_index,
"iteration": day_n
}
)
print("Starting Scheduler...")
scheduler.start_remotely("services-py311")
print("okay running", scheduler.get_scheduled_tasks())
except Exception as e:
print(f"Error occurred: {str(e)}")
Thanks!
128 Views
0
Answers
10 months ago
10 months ago