@@ -37,7 +37,7 @@ def create_job(self, name=None, existing_cluster_id=None, new_cluster=None, libr
3737 email_notifications = None , timeout_seconds = None , max_retries = None ,
3838 min_retry_interval_millis = None , retry_on_timeout = None , schedule = None ,
3939 notebook_task = None , spark_jar_task = None , spark_python_task = None ,
40- spark_submit_task = None , max_concurrent_runs = None , tasks = None , headers = None , version = None ):
40+ spark_submit_task = None , max_concurrent_runs = None , tasks = None , headers = None , version = None , git_source = None ):
4141 _data = {}
4242 if name is not None :
4343 _data ['name' ] = name
@@ -85,6 +85,8 @@ def create_job(self, name=None, existing_cluster_id=None, new_cluster=None, libr
8585 _data ['max_concurrent_runs' ] = max_concurrent_runs
8686 if tasks is not None :
8787 _data ['tasks' ] = tasks
88+ if git_source is not None :
89+ _data ['git_source' ] = git_source
8890 return self .client .perform_query ('POST' , '/jobs/create' , data = _data , headers = headers , version = version )
8991
9092 def submit_run (self , run_name = None , existing_cluster_id = None , new_cluster = None , libraries = None ,
0 commit comments