Enable inlets and outlets using DBT Fusion on Airflow 3

[ichirotakami]

Description

This PR enables inlets and outlets on Airflow 3 using DBT Fusion when using DbtRunOperationLocalOperator, by letting DbtLocalArtifactProcessor() find --profiles-dir by passing dbt_command_line tocalculate_openlineage_events_completes as dbt-fusion does not write profiles_dir into run_results.json.

Please see #2560 for more details about the issue.

Related Issue(s)

closes: #2560

Breaking Change?

Checklist

• I have made corresponding changes to the documentation (if required)
• I have added tests that prove my fix is effective or that my feature works

[Copilot]

Pull request overview

This PR fixes missing Airflow 3 inlets/outlets when running dbt-fusion via DbtRunOperationLocalOperator by ensuring OpenLineage’s DbtLocalArtifactProcessor can locate --profiles-dir (since dbt-fusion doesn’t write profiles_dir into run_results.json).

Changes:

• Pass the full dbt CLI command (full_cmd) into calculate_openlineage_events_completes and forward it as dbt_command_line to DbtLocalArtifactProcessor.
• Update the unit test that calls calculate_openlineage_events_completes to match the new method signature.

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 3 comments.

File	Description
cosmos/operators/local.py	Threads the dbt command line into the OpenLineage artifact processor so profiles discovery works with dbt-fusion on Airflow 3.
tests/operators/test_local.py	Updates a unit test invocation to include the new dbt_command_line argument.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[codecov]

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 98.05%. Comparing base (fa3828b) to head (54f392c).
⚠️ Report is 2 commits behind head on main.

Additional details and impacted files

@@           Coverage Diff           @@
##             main    #2561   +/-   ##
=======================================
  Coverage   98.04%   98.05%           
=======================================
  Files         103      103           
  Lines        7589     7593    +4     
=======================================
+ Hits         7441     7445    +4     
  Misses        148      148           

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

[tatiana]

HI @ichirotakami , thank you very much for fixing this issue!

Please, could you address The feedback in the comments:
#2561 (comment)
#2561 (comment)

[Copilot]

Pull request overview

Copilot reviewed 2 out of 2 changed files in this pull request and generated no new comments.

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[ichirotakami]

Hi @tatiana, thank you for your response. I have attempted to address the feedback with a new commit. Please let me know if you think I need to change something.

[Copilot]

Pull request overview

Copilot reviewed 2 out of 2 changed files in this pull request and generated no new comments.

Comments suppressed due to low confidence (1)

cosmos/operators/local.py:727

• The calculate_openlineage_events_completes docstring is now missing any mention of the new optional dbt_command_line parameter, and it still states it "Return[s] a list of RunEvents" even though the method returns None and mutates self.openlineage_events_completes. Please update the docstring to reflect the current behavior and document how dbt_command_line is used (e.g., to help OpenLineage locate --profiles-dir for dbt-fusion runs).

    def calculate_openlineage_events_completes(
        self,
        env: dict[str, str | os.PathLike[Any] | bytes],
        project_dir: Path,
        dbt_command_line: list[str] | None = None,
    ) -> None:
        """
        Use openlineage-integration-common to extract lineage events from the artifacts generated after running the dbt
        command. Relies on the following files:
        * profiles
        * {project_dir}/target/manifest.json
        * {project_dir}/target/run_results.json

        Return a list of RunEvents
        """

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[tatiana]

Thank you very much, @ichirotakami , it looks very good - and the context you gave in the issue was also amazing, it really helped understanding the underlining issue.