[Bug] Airflow 2.10 compatibility

[ms32035]

[Bug] Airflow 2.10 compatibility

[dosubot]

To resolve the AttributeError: 'DbtRunLocalOperator' object has no attribute '_BaseOperator__init_kwargs' when using Airflow 2.10 with Astronomer Cosmos 1.5.1, ensure that the DbtRunLocalOperator is properly initialized. This error typically occurs when the base class's __init__ method is not called correctly.

Here's an example of how to ensure proper initialization:

from cosmos.operators.local import DbtRunLocalOperator

class CustomDbtRunLocalOperator(DbtRunLocalOperator):
    def __init__(self, **kwargs):
        super().__init__(**kwargs)
        # Additional initialization if needed

# Usage
custom_operator = CustomDbtRunLocalOperator(
    task_id='dbt_run_task',
    profile_config=ProfileConfig(...),  # Provide necessary profile configuration
    invocation_mode=InvocationMode.SUBPROCESS,  # or InvocationMode.DBT_RUNNER
    install_deps=True,
    callback=None,
    should_store_compiled_sql=True,
    append_env=True,
    # other necessary parameters
)

Make sure that the super().__init__(**kwargs) line is present in your custom operator's __init__ method to properly initialize the base class. This should resolve the AttributeError. Additionally, ensure that you provide all required parameters such as profile_config, invocation_mode, and others as needed by the DbtLocalBaseOperator class ^[1][2].

There are also known compatibility issues between Airflow 2.10 and Astronomer Cosmos 1.5.1 documented in the repository, which might be contributing to the problem ^[3].

To continue talking to Dosu, mention @dosu.

[pankajastro]

Feel free to submit a PR whenever you're ready. I'm happy to review and merge it.

[pankajastro]

It looks like a side effect of the changes in PR apache/airflow#41085. A quick workaround is to add the missing __init__ method, which I have added in #1162. Let's see how CI feel.