InProcessExecutorOptions

kedro_dagster.config.models.InProcessExecutorOptions

Bases: BaseModel

Options for the in-process executor.

Parameters

Name	Type	Description	Default
retries	RetriesEnableOptions or RetriesDisableOptions	Retry configuration for the executor.	required

Examples

executors:
    local_inproc:
        in_process: {}
jobs:
    my_job:
        pipeline:
            pipeline_name: my_pipeline
        executor: local_inproc

See Also

kedro_dagster.config.models.MultiprocessExecutorOptions : Extends this class with concurrency settings. kedro_dagster.dagster.ExecutorCreator : Builds Dagster executor definitions from these options.

Source Code

View on GitHub

Show/Hide source

class InProcessExecutorOptions(BaseModel):
    """Options for the in-process executor.

    Parameters
    ----------
    retries : RetriesEnableOptions or RetriesDisableOptions
        Retry configuration for the executor.

    Examples
    --------
    ```yaml
    executors:
        local_inproc:
            in_process: {}
    jobs:
        my_job:
            pipeline:
                pipeline_name: my_pipeline
            executor: local_inproc
    ```

    See Also
    --------
    `kedro_dagster.config.models.MultiprocessExecutorOptions` :
        Extends this class with concurrency settings.
    `kedro_dagster.dagster.ExecutorCreator` :
        Builds Dagster executor definitions from these options.
    """

    class RetriesEnableOptions(BaseModel):
        """Enable retries for the executor."""

        enabled: dict = {}  # type: ignore[type-arg]

    class RetriesDisableOptions(BaseModel):
        """Disable retries for the executor."""

        disabled: dict = {}  # type: ignore[type-arg]

    retries: RetriesEnableOptions | RetriesDisableOptions = Field(
        default=RetriesEnableOptions(),
        description="Whether retries are enabled or not.",
    )

Methods

RetriesEnableOptions

Bases: BaseModel

Enable retries for the executor.

Source Code

View on GitHub

Show/Hide source

class RetriesEnableOptions(BaseModel):
    """Enable retries for the executor."""

    enabled: dict = {}  # type: ignore[type-arg]

RetriesDisableOptions

Bases: BaseModel

Disable retries for the executor.

Source Code

View on GitHub

Show/Hide source

class RetriesDisableOptions(BaseModel):
    """Disable retries for the executor."""

    disabled: dict = {}  # type: ignore[type-arg]