mirror/opencloud
1
0
Fork 0
mirror of https://github.com/opencloud-eu/opencloud.git synced 2026-04-22 19:19:18 -05:00
Code Issues Packages Projects Releases Wiki Activity

Add reusable context.

Browse Source
This commit is contained in:
Daniël Franke
2023-08-11 11:17:16 +02:00
parent 952ebe7d7d
commit 97dd855a63
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/postprocessing/pkg/service/service.go
+3 -2
View File
@@ -47,6 +47,7 @@ func NewPostprocessingService(stream events.Stream, logger log.Logger, sto store
// Run to fulfil Runner interface
func (pps *PostprocessingService) Run() error {
ctx := context.Background()
for e := range pps.events {
var (
next interface{}
@@ -89,7 +90,7 @@ func (pps *PostprocessingService) Run() error {
pp, err = getPP(pps.store, ev.UploadID)
if err != nil {
if err == store.ErrNotFound {
if err := events.Publish(context.Background(), pps.pub, events.RestartPostprocessing{
if err := events.Publish(ctx, pps.pub, events.RestartPostprocessing{
UploadID: ev.UploadID,
Timestamp: ev.Timestamp,
}); err != nil {
@@ -110,7 +111,7 @@ func (pps *PostprocessingService) Run() error {
}
}
if next != nil {
if err := events.Publish(context.Background(), pps.pub, next); err != nil {
if err := events.Publish(ctx, pps.pub, next); err != nil {
pps.log.Error().Err(err).Msg("unable to publish event")
return err // we can't publish -> we are screwed
}