Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 7 additions & 7 deletions api/py/ai/chronon/repo/run.py
Original file line number Diff line number Diff line change
Expand Up @@ -522,10 +522,10 @@ def run(self):
else:
# offline mode

# we'll always download the jar for now so that we can pull
# Always download the jar for now in dataproc mode so that we can pull
# in any fixes or latest changes
dataproc_jar = download_dataproc_jar(temp_dir,
get_customer_id())
if self.dataproc:
dataproc_jar = download_dataproc_jar(temp_dir, get_customer_id())

if self.parallelism > 1:
assert self.start_ds is not None and self.ds is not None, (
Expand All @@ -538,8 +538,8 @@ def run(self):
for start_ds, end_ds in date_ranges:
if not self.dataproc:
command = (
"bash {script} --class ai.chronon.spark.Driver {jar} {subcommand} {args} "
+ "{additional_args}"
"bash {script} --class ai.chronon.spark.Driver " +
"{jar} {subcommand} {args} {additional_args}"
).format(
script=self.spark_submit,
jar=self.jar_path,
Expand Down Expand Up @@ -580,8 +580,8 @@ def run(self):
else:
if not self.dataproc:
command = (
"bash {script} --class ai.chronon.spark.Driver {jar} {subcommand} {args} " +
"{additional_args}"
"bash {script} --class ai.chronon.spark.Driver "
+ "{jar} {subcommand} {args} {additional_args}"
).format(
script=self.spark_submit,
jar=self.jar_path,
Expand Down
Loading