logicamp/flink-kube-operator
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: create multiple managedJob instance

Browse Source
This commit is contained in:
Mohamad Khani
2024-12-01 00:07:30 +03:30
parent 6bd197b812
commit 64e84c8d0f
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
internal/manager/manager.go
View File

@@ -36,7 +36,8 @@ func cycle(client *api.Client, db *buntdb.DB) {
if ok { if ok {
} else { } else {
managed_job.NewManagedJob(client, db, job) managedJob := managed_job.NewManagedJob(client, db, job)
managedJobs[uid] = *managedJob
} }
} }
} }