Skip to content

Commit

Permalink
Added force flag
Browse files Browse the repository at this point in the history
  • Loading branch information
paulorijnberg authored and resulyrt93 committed Oct 10, 2023
1 parent 652d6b7 commit 833e18f
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
5 changes: 3 additions & 2 deletions dagster_meltano/ops.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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(
Expand Down
4 changes: 2 additions & 2 deletions pyproject.toml
Original file line number Diff line number Diff line change
@@ -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 = [
Expand Down

0 comments on commit 833e18f

Please sign in to comment.