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

@@ -142,9 +142,9 @@ def read_accessor_from_file(filename: str, accessor_id: Union[str, None] = None)
 
 
 @app.put('/accessors/write_to_file/{accessor_id}')
-def write_accessor_to_file(accessor_id: str, filename: Union[str, None] = None) -> str:
+def write_accessor_to_file(accessor_id: str, filename: Union[str, None] = None, pop: bool = True) -> str:
     try:
-        return session.write_accessor(accessor_id, filename)
+        return session.write_accessor(accessor_id, filename, pop=pop)
     except AccessorIdError as e:
         raise HTTPException(404, f'Did not find accessor with ID {accessor_id}')
     except WriteAccessorError as e: