Skip to content

Commit

Permalink
fix(resource): use meltano_bin param (#55)
Browse files Browse the repository at this point in the history
  • Loading branch information
tomtomau authored Oct 29, 2024
1 parent 606252b commit b65451c
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dagster_meltano/meltano_resource.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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,
Expand Down

0 comments on commit b65451c

Please sign in to comment.