From 64081b33d9eb1ad415c4b2ce0e6faec275670433 Mon Sep 17 00:00:00 2001 From: Maciej Gierada Date: Thu, 5 Oct 2023 11:59:18 +0200 Subject: [PATCH] feat: remove type annotation for context param in meltano_install op --- dagster_meltano/ops.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/dagster_meltano/ops.py b/dagster_meltano/ops.py index 44fbd45..ea8cdf1 100644 --- a/dagster_meltano/ops.py +++ b/dagster_meltano/ops.py @@ -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 @@ -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( @@ -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. """