Skip to main content

Hi I have pipeline and it has 1 runtime parameter about table name. I create a job on top of this pipeline, so it also has a runtime parameter, when create job from this pipeline, I provide a default parameter.

I try to use python SDK to call the job, if I ran like below, the job will run with the default parameter(TEST_TABLE1) defined in pipeline and job, it is expected:

job = sch.jobs.get(job_name = "MY_SDC_JOB")

sch.start_job(job)

 

However when I run like this, I want to overwrite the default runtime parameter, but it still using the default parameter(TEST_TABLE1) , how to make it run with the given parameter(TEST_TABLE2)?

sch.start_job(job, TABLE_NAME=’TEST_TABLE2')

Be the first to reply!

Reply