diff --git a/server/src/workflow-management/integrations/gsheet.ts b/server/src/workflow-management/integrations/gsheet.ts index e2660b9b..3ce55341 100644 --- a/server/src/workflow-management/integrations/gsheet.ts +++ b/server/src/workflow-management/integrations/gsheet.ts @@ -94,7 +94,7 @@ export async function writeDataToSheet(fileName: string, spreadsheetId: string, } } -const processGoogleSheetUpdates = async () => { +export const processGoogleSheetUpdates = async () => { while (true) { let hasPendingTasks = false; for (const runId in googleSheetUpdateTasks) { @@ -122,9 +122,4 @@ const processGoogleSheetUpdates = async () => { await new Promise(resolve => setTimeout(resolve, 5000)); } }; - -export const startProcessGoogleSheetUpdates = () => { - if (Object.keys(googleSheetUpdateTasks).length > 0) { - processGoogleSheetUpdates(); - } -}; \ No newline at end of file + \ No newline at end of file