From cabf2e63d1277f0af57a8068901ea9fb35983f61 Mon Sep 17 00:00:00 2001 From: Paulo Rijnberg Date: Thu, 21 Sep 2023 11:55:13 +0000 Subject: [PATCH] Added force flag --- dagster_meltano/ops.py | 5 +++-- pyproject.toml | 4 ++-- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/dagster_meltano/ops.py b/dagster_meltano/ops.py index 93242c9..44fbd45 100644 --- a/dagster_meltano/ops.py +++ b/dagster_meltano/ops.py @@ -91,7 +91,8 @@ 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 @@ -110,7 +111,7 @@ def meltano_run_op( same repository. """ dagster_name = generate_dagster_name(command) - return meltano_command_op(command=f"run {command}", dagster_name=dagster_name) + return meltano_command_op(command=f"run {command} --force", dagster_name=dagster_name) @op( diff --git a/pyproject.toml b/pyproject.toml index 1210195..929e2b3 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,8 +1,8 @@ [tool.poetry] name = "dagster-meltano" -version = "1.4.0" +version = "1.5.0" description = "A dagster plugin that allows you to run your Meltano project inside Dagster." -authors = ["Jules Huisman"] +authors = ["Quantile Development"] license = "Apache 2.0" readme = "README.md" packages = [