Pipeline task management

Session persists a collection of tasks with unique identifiers; shared pipeline caller can optionally enqueue its call as a task instead of running it directly

model_server/base/api.py

@@ -213,13 +213,18 @@ class TaskInfo(BaseModel):
     error: Union[str, None]
     result: Union[Dict, None]
 
-# TODO: cover is API tests, with dummy task resource endpoint
+# TODO: cover task API with tests, using dummy task resource endpoint
 
-@app.get('/tasks/{task_id')
+# TODO: return something smarter than bool
+@app.put('/tasks/{task_id}/run')
+def run_task(task_id: str) -> bool:
+    return session.queue.run_task(task_id)
+
+@app.get('/tasks/{task_id}')
 def get_task(task_id: str) -> TaskInfo:
     return session.queue.get_task_info(task_id)
 
 @app.get('/tasks')
 def list_tasks() -> Dict[str, TaskInfo]:
     res = session.queue.list_tasks()
-    return res
\ No newline at end of file
+    return res