Skip to content

Commit ac09af9

Browse files
committed
airflow: Fix nil pointer dereference when unlock dag request
1 parent 6175109 commit ac09af9

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

lib/airflow/workflow.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,11 @@ func callDagRequestLock(workflowID string) func() {
3131
dagRequests[workflowID].Lock()
3232

3333
return func() {
34+
_, exist := dagRequests[workflowID]
35+
if !exist {
36+
return
37+
}
38+
3439
dagRequests[workflowID].Unlock()
3540

3641
dagRequestsLock.Lock()

0 commit comments

Comments
 (0)