嗨@sharpbetty,
一個可能的解決方案是使用任務值傳遞參數從任務1到2,然後使用一塊try-except任務2處理情況1失敗。這裏是實現這個解決方案的步驟:
1。在任務1中,使用
dbutils.jobs.taskValues.set ()
命令來設置任務的參數值。例如:
python dbutils.jobs.taskValues。集(鍵=“param1”,值= 42)dbutils.jobs.taskValues。集(鍵=“param2”,值=“foo”)
2。在任務2中,使用
dbutils.jobs.taskValues.get ()
命令來檢索參數作為任務值。例如:
python嚐試:param1 = dbutils.jobs.taskValues。get (taskKey = " Task 1 ",關鍵=“param1”) param2 = dbutils.jobs.taskValues。get (taskKey = " Task 1 ",關鍵=“param2”)除了ValueError: #處理情況任務1失敗param1 =沒有param2 =沒有
3所示。使用
param1
和
param2
任務2中變量生成report.4。如果你想讓Task 2報告“失敗”如果Task 1失敗,您可以添加一個檢查任務2的末尾,看看
param1
和
param2
是
沒有一個
。如果它們,那麼任務1失敗,任務2應該報告“失敗”。
例如:
python如果沒有或param2 param1沒有:1 #任務失敗,報告“失敗”dbutils.notebook.exit(“失敗”)其他:#任務1成功,生成報告……
Task 2仍然可以運行即使任務1失敗通過任務值函數之間傳遞參數。任務2中的try-except塊允許您處理任務1失敗的情況,仍然生成報告如果Task 1成功。檢查任務2的末尾將使您能夠報告“失敗”如果Task 1失敗。