From b65451c1119e00f9c328e7fb63e25134d87a85e1 Mon Sep 17 00:00:00 2001 From: Tom Newby Date: Tue, 29 Oct 2024 22:57:58 +1000 Subject: [PATCH] fix(resource): use meltano_bin param (#55) --- dagster_meltano/meltano_resource.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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,