diff --git a/api/py/ai/chronon/repo/run.py b/api/py/ai/chronon/repo/run.py index 88036b095..7ee1a34ce 100755 --- a/api/py/ai/chronon/repo/run.py +++ b/api/py/ai/chronon/repo/run.py @@ -506,7 +506,7 @@ def _gen_final_args(self, start_ds=None, end_ds=None): online_jar=self.online_jar, online_class=self.online_class, ) - override_start_partition_arg = "--start-partition-override=" + start_ds if start_ds else "" + override_start_partition_arg = " --start-partition-override=" + start_ds if start_ds else "" final_args = base_args + " " + str(self.args) + override_start_partition_arg return final_args