diff options
Diffstat (limited to 'plugins/jobs/brokers/ephemeral/item.go')
| -rw-r--r-- | plugins/jobs/brokers/ephemeral/item.go | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/plugins/jobs/brokers/ephemeral/item.go b/plugins/jobs/brokers/ephemeral/item.go index e2caa53a..40c6b3e4 100644 --- a/plugins/jobs/brokers/ephemeral/item.go +++ b/plugins/jobs/brokers/ephemeral/item.go @@ -103,10 +103,12 @@ func (j *Item) Body() []byte { func (j *Item) Context() ([]byte, error) { ctx, err := json.Marshal( struct { - ID string `json:"id"` - Job string `json:"job"` - Headers map[string][]string `json:"headers"` - }{ID: j.Ident, Job: j.Job, Headers: j.Headers}, + ID string `json:"id"` + Job string `json:"job"` + Headers map[string][]string `json:"headers"` + Timeout uint64 `json:"timeout"` + Pipeline string `json:"pipeline"` + }{ID: j.Ident, Job: j.Job, Headers: j.Headers, Timeout: j.Options.Timeout, Pipeline: j.Options.Pipeline}, ) if err != nil { |