update operator function name

NatLibFi · Sep 24, 2024 · 33eb737 · 33eb737
1 parent 464ef01
commit 33eb737
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/app.js b/src/app.js
@@ -1,12 +1,12 @@
 import {createLogger} from '@natlibfi/melinda-backend-commons';
-import {transformerBlobLogic, createMongoOperator} from '@natlibfi/melinda-record-import-commons';
+import {transformerBlobLogic, createMongoBlobsOperator} from '@natlibfi/melinda-record-import-commons';
 import createTransformHandler from './transform';
 import amqplib from 'amqplib';
 
 export async function startApp(config) {
   const logger = createLogger();
 
-  const mongoOperator = await createMongoOperator(config.mongoUrl);
+  const mongoOperator = await createMongoBlobsOperator(config.mongoUrl);
   const transformHandler = createTransformHandler(config);
 
   logger.info('Starting melinda record import dc transformer');