fix operator for sql application name

hasadna · Oct 30, 2024 · 88f94a7 · 88f94a7
1 parent 0cec5bb
commit 88f94a7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/open_bus_pipelines/operators/cli_bash_operator.py b/open_bus_pipelines/operators/cli_bash_operator.py
@@ -20,6 +20,7 @@ class CliBashOperator(BashOperator):
 
     def __init__(self, cmd, **kwargs):
         assert not kwargs.get('bash_command')
+        kwargs['bash_command'] = '_'
         super(CliBashOperator, self).__init__(**kwargs)
         self.bash_command = '{print_dag_run}{pip_install_deps}{ENV}{STRIDE_VENV}/bin/{cmd}'.format(
             ENV=f'SQLALCHEMY_APPLICATION_NAME="{self.task_id}" SQLALCHEMY_APPLICATION_VERSION="$(cat {STRIDE_VENV}/open_bus_pipelines_commit.txt)" ',