This commit is contained in:
Robert Lin 2024-07-18 15:45:41 -07:00
parent 1b9b37f27d
commit b125b3ecc7

View File

@ -110,7 +110,6 @@ func (Service) Initialize(ctx context.Context, logger log.Logger, contract runti
config.CodyGatewayEvents),
},
),
dotcomDB,
connect.WithInterceptors(otelConnctInterceptor),
)
subscriptionsservice.RegisterV1(
@ -203,7 +202,7 @@ func (Service) Initialize(ctx context.Context, logger log.Logger, contract runti
},
},
// Run importer in background
importer.New(ctx, logger.Scoped("importer"), dotcomDB, dbHandle, config.DotComDB.ImportInterval),
importer.NewPeriodicImporter(ctx, logger.Scoped("importer"), dotcomDB, dbHandle, config.DotComDB.ImportInterval),
// Stop server first
server,
}, nil