{"record":{"id":"2c5a2e37380144a2","repo":"conductor-oss/conductor","slug":"unable-to-find-queue-name-for-task-s","errorCode":null,"errorMessage":"Unable to find queue name for task %s","messagePattern":"Unable to find queue name for task (.+?)","errorType":"exception","errorClass":"NonTransientException","httpStatus":null,"severity":"error","filePath":"core/src/main/java/com/netflix/conductor/core/execution/tasks/Event.java","lineNumber":168,"sourceCode":"            }\n        }\n        return queueName;\n    }\n\n    @VisibleForTesting\n    ObservableQueue getQueue(String queueName, String taskId) {\n        try {\n            return eventQueues.getQueue(queueName);\n        } catch (IllegalArgumentException e) {\n            throw new IllegalStateException(\n                    \"Error loading queue:\"\n                            + queueName\n                            + \", for task:\"\n                            + taskId\n                            + \", error: \"\n                            + e.getMessage());\n        } catch (Exception e) {\n            throw new NonTransientException(\"Unable to find queue name for task \" + taskId);\n        }\n    }\n\n    Message getPopulatedMessage(TaskModel task) throws JsonProcessingException {\n        String payloadJson = objectMapper.writeValueAsString(task.getOutputData());\n        return new Message(task.getTaskId(), payloadJson, task.getTaskId());\n    }\n}\n","sourceCodeStart":150,"sourceCodeEnd":177,"githubUrl":"https://github.com/conductor-oss/conductor/blob/cf7c3e4a8adfb158be778ab1ec525323c363cd3a/core/src/main/java/com/netflix/conductor/core/execution/tasks/Event.java#L150-L177","documentation":"Thrown by Event.getQueue() as a catch-all when eventQueues.getQueue() throws any exception other than IllegalArgumentException. Unlike the more specific IllegalStateException (error 436), this wraps unexpected failures (NPE, IOException, connection errors to the queue backend) into a NonTransientException. The message does not include the original exception — only the taskId. NonTransientException means retrying the same task will produce the same failure.","triggerScenarios":"The queue provider's getQueue() method throws a non-IllegalArgumentException due to a backend connection failure, NPE in provider initialization, or a configuration error in the provider implementation. The queue backend (e.g., SQS, AMQP broker) is unreachable or misconfigured.","commonSituations":"SQS/AMQP credentials are invalid or expired. The queue provider bean failed to initialize but was not caught at startup. Network partition between Conductor server and the message broker.","solutions":["Check the server log for the original exception — the catch block does not include it in the message, so look in logs.","Verify the event queue backend connectivity (SQS endpoint, AMQP broker URL, credentials).","Ensure the event queue provider is correctly configured in application properties.","If the provider has a transient connectivity issue, the NonTransientException classification may be too aggressive — consider restarting the provider connection."],"exampleFix":null,"handlingStrategy":"try-catch","validationCode":"// Verify queue backend connectivity before task execution\ntry {\n    ObservableQueue queue = eventQueues.getQueue(queueName);\n    queue.ack(List.of()); // test connectivity\n} catch (Exception e) {\n    throw new IllegalStateException(\"Queue backend unreachable: \" + e.getMessage());\n}","typeGuard":null,"tryCatchPattern":"try {\n    ObservableQueue queue = eventQueues.getQueue(queueName);\n} catch (IllegalArgumentException e) {\n    // handled by error 436\n} catch (Exception e) {\n    LOGGER.error(\"Queue backend error for {}: {}\", queueName, e.getMessage());\n    // NonTransientException — cannot recover without fixing backend config\n}","preventionTips":["Monitor event queue backend health (SQS, AMQP) from infrastructure dashboards.","Verify credentials and connectivity for queue providers at startup.","Review server logs for the root cause — the error message does not include it."],"tags":["event-task","queue","provider","non-transient","connectivity"],"backgroundTag":null,"analyzedSha":"cf7c3e4a8adfb158be778ab1ec525323c363cd3a","analyzedAt":"2026-08-14T03:33:19.897Z","schemaVersion":2},"datasetVersion":"2026-08-14T05:17:29.042Z"}