diff --git a/dagster_meltano/meltano_resource.py b/dagster_meltano/meltano_resource.py index d7dc768..3a8bd90 100644 --- a/dagster_meltano/meltano_resource.py +++ b/dagster_meltano/meltano_resource.py @@ -59,7 +59,7 @@ def execute_command( str: The output of the command. """ output, exit_code = execute_shell_command( - f"meltano {command}", + f"{self.meltano_bin} {command}", env={**self.default_env, **env}, output_logging="STREAM", log=logger, @@ -85,7 +85,7 @@ async def load_json_from_cli(self, command: List[str]) -> dict: """ # Create the subprocess, redirect the standard output into a pipe proc = await asyncio.create_subprocess_exec( - "meltano", + self.meltano_bin, *command, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE,