diff options
Diffstat (limited to 'plugins/jobs/brokers/ephemeral/broker.go')
| -rw-r--r-- | plugins/jobs/brokers/ephemeral/broker.go | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/plugins/jobs/brokers/ephemeral/broker.go b/plugins/jobs/brokers/ephemeral/broker.go index 4bbb4095..6c7108f6 100644 --- a/plugins/jobs/brokers/ephemeral/broker.go +++ b/plugins/jobs/brokers/ephemeral/broker.go @@ -57,12 +57,6 @@ func (j *JobBroker) Register(pipeline string) error { return nil } -func (j *JobBroker) PushBatch(job *[]structs.Job) (*string, error) { - // Use a batch response - // Add JobID to the payload to match responses - panic("todo") -} - func (j *JobBroker) Stop(pipeline string) { if q, ok := j.queues.Load(pipeline); ok { if q == true { |