Worker & executor signatures

The worker & executor signatures the Python SDK declares, straight from its own declarations.

Signatures, parameters, defaults and return types come straight from the declarations, so they cannot drift from the code. Prose, examples and gotchas live on the hand-written pages this section sits beside.

Generated from sdks/python/flexiq/_flexiq.pyi.

Executor

`Executor()`

python

Executor(
    address: str,
    app_path: str,
    tasks: list[str],
    slots: int,
    token: str | None = None,
    executor_id: str | None = None,
    tls_ca: str | os.PathLike[str] | None = None,
    tls_cert: str | os.PathLike[str] | None = None,
    tls_key: str | os.PathLike[str] | None = None
)

`executor.executor_id`

python

executor.executor_id: str

`executor.is_running()`

python

executor.is_running() -> bool

`executor.peer`

python

executor.peer: str

`executor.scheduler_id`

python

executor.scheduler_id: str

`executor.shutdown()`

python

executor.shutdown() -> None

`executor.stop()`

python

executor.stop() -> None

`executor.wait()`

python

executor.wait(timeout_ms: int) -> bool

PyResultSender

`sender.try_report_cancelled()`

python

sender.try_report_cancelled(
    job_id: str,
    task_name: str,
    wall_time_ns: int
) -> bool

`sender.try_report_failure()`

python

sender.try_report_failure(
    job_id: str,
    task_name: str,
    error: str,
    retry_count: int,
    max_retries: int,
    wall_time_ns: int,
    should_retry: bool
) -> bool

`sender.try_report_slept()`

python

sender.try_report_slept(
    job_id: str,
    task_name: str,
    wake_at: int,
    wall_time_ns: int
) -> bool

`sender.try_report_success()`

python

sender.try_report_success(
    job_id: str,
    task_name: str,
    result: bytes | None,
    wall_time_ns: int
) -> bool