diff options
| author | George Goldberg <george@gberg.me> | 2018-05-31 10:25:31 +0100 |
|---|---|---|
| committer | George Goldberg <george@gberg.me> | 2018-05-31 10:25:31 +0100 |
| commit | 27e7841a734e9c3ed71f988a653f5865d2ef6f91 (patch) | |
| tree | 1ccc65246fb166c25a9923f4e05ad7d6223892d1 /jobs/jobs_watcher.go | |
| parent | e39f5f46f3f6cdcb7ab8aeef8c601047f5942f85 (diff) | |
| parent | 994ccf475f96bcad668269fe25b0d22e975bc222 (diff) | |
| download | chat-27e7841a734e9c3ed71f988a653f5865d2ef6f91.tar.gz chat-27e7841a734e9c3ed71f988a653f5865d2ef6f91.tar.bz2 chat-27e7841a734e9c3ed71f988a653f5865d2ef6f91.zip | |
Merge branch 'advanced-permissions-phase-2'
Diffstat (limited to 'jobs/jobs_watcher.go')
| -rw-r--r-- | jobs/jobs_watcher.go | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/jobs/jobs_watcher.go b/jobs/jobs_watcher.go index 07979442d..01d0a8d0f 100644 --- a/jobs/jobs_watcher.go +++ b/jobs/jobs_watcher.go @@ -107,6 +107,13 @@ func (watcher *Watcher) PollAndNotify() { default: } } + } else if job.Type == model.JOB_TYPE_MIGRATIONS { + if watcher.workers.Migrations != nil { + select { + case watcher.workers.Migrations.JobChannel() <- *job: + default: + } + } } } } |