diff --git a/pkg/gordio/server/ingest.go b/pkg/gordio/server/ingest.go index 2c5a868..383cbb0 100644 --- a/pkg/gordio/server/ingest.go +++ b/pkg/gordio/server/ingest.go @@ -4,13 +4,8 @@ import ( "context" "dynatron.me/x/stillbox/pkg/gordio/calls" - "dynatron.me/x/stillbox/pkg/gordio/database" ) func (s *Server) Ingest(ctx context.Context, call *calls.Call) { - // decouple this context from the one we call sinks with - db := database.FromCtx(ctx) - nctx := database.CtxWithDB(context.Background(), db) - - s.sinks.EmitCall(nctx, call) + s.sinks.EmitCall(context.Background(), call) }