Skip to content

Commit

Permalink
feat: remove type annotation for context param in meltano_install op (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
mgierada authored Oct 10, 2023
1 parent f4410d2 commit 2915428
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions dagster_meltano/ops.py
Original file line number Diff line number Diff line change
Expand Up @@ -91,8 +91,7 @@ def dagster_op(
env = {**env, **config_env}

# Run the Meltano command
output = meltano_resource.execute_command(
f"{command}", env, context.log)
output = meltano_resource.execute_command(f"{command}", env, context.log)

# Return the logs
return output
Expand All @@ -111,7 +110,9 @@ def meltano_run_op(
same repository.
"""
dagster_name = generate_dagster_name(command)
return meltano_command_op(command=f"run {command} --force", dagster_name=dagster_name)
return meltano_command_op(
command=f"run {command} --force", dagster_name=dagster_name
)


@op(
Expand All @@ -129,7 +130,7 @@ def meltano_run_op(
)
},
)
def meltano_install_op(context: OpExecutionContext):
def meltano_install_op(context):
"""
Run `meltano install` using a Dagster op.
"""
Expand Down

0 comments on commit 2915428

Please sign in to comment.