diff --git a/backend/cron/service.go b/backend/cron/service.go index b45b073f69..644a11cafc 100644 --- a/backend/cron/service.go +++ b/backend/cron/service.go @@ -47,6 +47,7 @@ func (c cronJob) String() string { // Start the cron service. Blocks until the context is cancelled. func Start(ctx context.Context, eventSource schemaeventsource.EventSource, client routing.CallClient) error { logger := log.FromContext(ctx).Scope("cron") + ctx = log.ContextWithLogger(ctx, logger) // Map of cron jobs for each module. cronJobs := map[string][]cronJob{} // Cron jobs ordered by next execution. diff --git a/backend/ingress/service.go b/backend/ingress/service.go index e921f3d9ab..48c757e304 100644 --- a/backend/ingress/service.go +++ b/backend/ingress/service.go @@ -45,6 +45,7 @@ type service struct { // Start the HTTP ingress service. Blocks until the context is cancelled. func Start(ctx context.Context, config Config, schemaEventSource schemaeventsource.EventSource, client routing.CallClient) error { logger := log.FromContext(ctx).Scope("http-ingress") + ctx = log.ContextWithLogger(ctx, logger) svc := &service{ view: syncView(ctx, schemaEventSource), client: client, diff --git a/backend/lease/service.go b/backend/lease/service.go index 5beeb0c76d..b522bf1818 100644 --- a/backend/lease/service.go +++ b/backend/lease/service.go @@ -41,6 +41,7 @@ func Start(ctx context.Context, config Config) error { svc := &service{ leases: make(map[string]*time.Time), } + ctx = log.ContextWithLogger(ctx, logger) logger.Debugf("Lease service listening on: %s", config.Bind) err := rpc.Serve(ctx, config.Bind, diff --git a/backend/timeline/service.go b/backend/timeline/service.go index 727604ef74..41747d7144 100644 --- a/backend/timeline/service.go +++ b/backend/timeline/service.go @@ -44,6 +44,7 @@ func Start(ctx context.Context, config Config) error { config.SetDefaults() logger := log.FromContext(ctx).Scope("timeline") + ctx = log.ContextWithLogger(ctx, logger) svc := &service{ config: config, events: make([]*timelinepb.Event, 0),