[TASK] Modify the apply endpoint in the REST API to an asynchronous interface.

[jieguangzhou]

When a component we add triggers long-running jobs, it is unreasonable for the entire endpoint to wait for all tasks to complete before responding.

The endpoint should return a success message after applying the component, while the jobs continue to run in the background.

from fastapi import FastAPI, BackgroundTasks

app = FastAPI()

def _apply_component(info: dict):
    return events

    
def push_events(events):
    .....

@app.add('/db/apply', method='post')
async  def db_apply(info: t.Dict, id: str | None = None, background_tasks: BackgroundTasks =None):
    events = _apply_component(info)

    background_tasks.add_task(push_events, events)
    
    return {'status': 'ok'}

[blythed]

Agreed. This is especially true in open-source. We also now have the ability to watch the log, even if the task is starting in the background.