pass specs through thread instead of redis

biothings · May 16, 2024 · 192f695 · 192f695
1 parent 061bb60
commit 192f695
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 12 deletions.
diff --git a/src/controllers/cron/update_local_smartapi.ts b/src/controllers/cron/update_local_smartapi.ts
@@ -333,17 +333,7 @@ async function updateSmartAPISpecs() {
  const metakg = new MetaKG();
  metakg.constructMetaKGSync(true, { predicates: predicatesInfo, smartapiSpecs: { hits: hits as any }, apiList });
  global.metakg = metakg;
-
- // write to the redis database
- if (redisClient.clientEnabled) {
- debug("Writing smartapi hits to redis");
- try {
- await redisClient.client.setTimeout(`bte:smartapi:specs`, JSON.stringify({ hits }));
- debug("Wrote smartapi hits to redis");
- } catch (e) {
- debug(`Error writing smartapi hits to redis: ${e}`);
- }
- }
+ global.smartapi = { hits };
 };
 
 async function getAPIOverrides(data: { total?: number; hits: any }, overrides: SmartApiOverrides) {

diff --git a/src/controllers/threading/threadHandler.ts b/src/controllers/threading/threadHandler.ts
@@ -111,7 +111,7 @@ async function queueTaskToWorkers(pool: Piscina, taskInfo: TaskInfo, route: stri
  const { traceparent, tracestate } = otelData;
 
  const taskData: InnerTaskData = { req: taskInfo, route, traceparent, tracestate, port: toWorker };
- taskData.req.data.options = {...taskData.req.data.options, metakg: global.metakg?.ops};
+ taskData.req.data.options = {...taskData.req.data.options, metakg: global.metakg?.ops, smartapi: global.smartapi};
 
  // Propagate data between task runner and bull job
  if (job) taskData.job = { jobId: job.id, queueName: job.queue.name };