From 430e1bc9c79aab6d7fa1af014b15de9e10477932 Mon Sep 17 00:00:00 2001 From: Darin Kelkhoff Date: Mon, 14 Nov 2022 14:00:48 -0600 Subject: [PATCH] Add table name to record pipe loop --- .../automation/polling/PollingAutomationPerTableRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/automation/polling/PollingAutomationPerTableRunner.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/automation/polling/PollingAutomationPerTableRunner.java index abe49edb..0e822b23 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/automation/polling/PollingAutomationPerTableRunner.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/automation/polling/PollingAutomationPerTableRunner.java @@ -212,7 +212,7 @@ public class PollingAutomationPerTableRunner implements Runnable /////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// RecordPipe recordPipe = new RecordPipe(); AsyncRecordPipeLoop asyncRecordPipeLoop = new AsyncRecordPipeLoop(); - asyncRecordPipeLoop.run("PollingAutomationRunner>Query>" + automationStatus, null, recordPipe, (status) -> + asyncRecordPipeLoop.run("PollingAutomationRunner>Query>" + automationStatus + ">" + table.getName(), null, recordPipe, (status) -> { QueryInput queryInput = new QueryInput(instance); queryInput.setSession(session);