Run

Run steps in parallel.

Arguments

  • Name
    step_id
    Type
    str
    Required
    required
    Description

    Step ID. Should be unique within the function.

  • Name
    handler
    Type
    Callable[[], object]
    Required
    required
    Description

    A callable that has no arguments and returns a JSON serializable value.

Examples

@inngest_client.create_function(
    fn_id="my_function",
    trigger=inngest.TriggerEvent(event="app/my_function"),
)
async def fn(
    ctx: inngest.Context,
    step: inngest.Step,
) -> int:
    async def my_step() -> int:
        # Do stuff
        return 1

    return await step.run("my_step", my_step)