Is it generally safe to run Flyte workflow from code directly, e.g. from a FastAPI endpoint? Assuming that my pipeline does not have any side effects, can I just launch it like that?

@workflow
def dummy_workflow(n: int) -> int:
    numbers = generate_numbers(n=n)
    squared_numbers = map_task(square)(x=numbers)
    total = sum_squares(squares=squared_numbers)
    return total


class Data(BaseModel):
    n: int = Field(ge=1, le=100)

@app.post("/workflow")
async def root(data: Data):
    result = dummy_workflow(n=data.n)
    return {
        "message": "Workflow executed",
        "result": result,
    }

The reason I'm asking is that I want to have a single pipeline abstraction across our code base

you can use flyteremote

better to use flyte remote to kick it of

But I want to run it locally, should I also use FlyteRemote abstractions then?

if you want to run locally

OK, thx!

yes