make default online jar and online class.

Author: david-zlai

api/py/ai/chronon/repo/run.py

@@ -668,8 +668,8 @@ def _gen_final_args(self, start_ds=None, end_ds=None, override_conf_path=None):
         base_args = MODE_ARGS[self.mode].format(
             conf_path=override_conf_path if override_conf_path else self.conf,
             ds=end_ds if end_ds else self.ds,
-            online_jar=self.online_jar if not self.dataproc else ZIPLINE_ONLINE_JAR_DEFAULT,
-            online_class=self.online_class if not self.dataproc else ZIPLINE_ONLINE_CLASS_DEFAULT,
+            online_jar=self.online_jar,
+            online_class=self.online_class,
         )
         override_start_partition_arg = (
             " --start-partition-override=" + start_ds if start_ds else ""
@@ -780,7 +780,7 @@ def generate_dataproc_submitter_args(local_files_to_upload_to_gcs: List[str], us
 
     # include chronon jar uri. should also already be in the bucket
     chronon_jar_uri = f"{zipline_artifacts_bucket_prefix}-{get_customer_id()}" + \
-        "/jars/cloud_gcp-assembly-0.1.0-SNAPSHOT.jar"
+                      "/jars/cloud_gcp-assembly-0.1.0-SNAPSHOT.jar"
 
     final_args = (f"{user_args} --additional-conf-path=additional-confs.yaml --gcs_files={gcs_file_args} "
                   f"--chronon_jar_uri={chronon_jar_uri}")
@@ -851,9 +851,11 @@ def upload_gcs_blob(bucket_name, source_file_name, destination_blob_name):
 @click.option("--parallelism", help="break down the backfill range into this number of tasks in parallel. "
                                     "Please use it along with --start-ds and --end-ds and only in manual mode")
 @click.option("--repo", help="Path to chronon repo")
-@click.option("--online-jar", help="Jar containing Online KvStore & Deserializer Impl. "
-                                   "Used for streaming and metadata-upload mode.")
-@click.option("--online-class", help="Class name of Online Impl. Used for streaming and metadata-upload mode.")
+@click.option("--online-jar", default="ZIPLINE_ONLINE_JAR_DEFAULT",
+              help="Jar containing Online KvStore & Deserializer Impl. "
+                   "Used for streaming and metadata-upload mode.")
+@click.option("--online-class", default="ZIPLINE_ONLINE_CLASS_DEFAULT",
+              help="Class name of Online Impl. Used for streaming and metadata-upload mode.")
 @click.option("--version", help="Chronon version to use.")
 @click.option("--spark-version", default="2.4.0", help="Spark version to use for downloading jar.")
 @click.option("--spark-submit-path", help="Path to spark-submit")