adjusting the return value type(None -> FullOutputSubprocessResult) f…

…or build_and_run_cmd() method
astronomer · Sep 27, 2023 · 200fb00 · 200fb00
1 parent 20ef37b
commit 200fb00
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cosmos/operators/local.py b/cosmos/operators/local.py
@@ -348,7 +348,7 @@ def get_openlineage_facets_on_complete(self, task_instance: TaskInstance) -> Ope
             job_facets=job_facets,
         )
 
-    def build_and_run_cmd(self, context: Context, cmd_flags: list[str] | None = None) -> None:
+    def build_and_run_cmd(self, context: Context, cmd_flags: list[str] | None = None) -> FullOutputSubprocessResult:
         dbt_cmd, env = self.build_cmd(context=context, cmd_flags=cmd_flags)
         dbt_cmd = dbt_cmd or []
         result = self.run_command(cmd=dbt_cmd, env=env, context=context)