Conductor is an event driven agentic workflow engine providing durable and highly resilient execution engine for applications and AI Agents
This report summarizes scanner evidence for conductor-oss/conductor, a Java project with 32,401 GitHub stars. SynthScan examined 654,866 lines of code across 3830 source files, recording 808 pattern matches distributed across 18 syntactic categories. The legacy adjusted pattern signal is 3.5 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 415 finding(s).
Are imports declared and package/API names verified? 55 finding(s).
Are wrappers, guards, and repeated structures necessary? 390 finding(s).
Which changes need focused human review? 808 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 808 distinct pattern matches across 18 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | ui/e2e/pages.spec.ts | 15 | // ── Executions ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui/e2e/pages.spec.ts | 43 | // ── Definitions ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui/e2e/pages.spec.ts | 101 | // ── Scheduler Executions ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui/e2e/pages.spec.ts | 118 | // ── Task Queue ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui/e2e/pages.spec.ts | 156 | // ── Workbench ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/workflow-execution-search-filters.spec.ts | 89 | // ─── Filter form ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/workflow-execution-search-filters.spec.ts | 197 | // ─── Execution start time picker ─────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/workflow-execution-search-filters.spec.ts | 315 | // ─── SQL toggle mode ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 16 | // ── Types ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 118 | // ── Helpers ─────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 140 | // ── Workflow definitions ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 167 | // ── Workflow executions ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 278 | // ── Task definitions ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 293 | // ── Event handlers ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 331 | // ── Scheduler definitions & executions ───────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 486 | // ── Agents (AgentSpan — requires conductor.integrations.ai.enabled=true) ─────── | COMMENT |
| MEDIUM | …xt/e2e/integration/workflow-execution-complete.spec.ts | 294 | // ── Helpers ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …xt/e2e/integration/workflow-execution-complete.spec.ts | 440 | // ── Tests ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | …xt/e2e/integration/workflow-execution-complete.spec.ts | 812 | // ════════════════════════════════════════════════════════════════════════════ | COMMENT |
| MEDIUM⚡ | …xt/e2e/integration/workflow-execution-complete.spec.ts | 817 | // ════════════════════════════════════════════════════════════════════════════ | COMMENT |
| MEDIUM⚡ | …xt/e2e/integration/workflow-execution-complete.spec.ts | 819 | // ── Workflow definitions ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …xt/e2e/integration/workflow-execution-complete.spec.ts | 928 | // ── Helper — wait until a specific task reaches SCHEDULED or IN_PROGRESS ───── | COMMENT |
| MEDIUM | …xt/e2e/integration/workflow-execution-complete.spec.ts | 952 | // ── Test suite ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …xt/e2e/integration/workflow-execution-complete.spec.ts | 984 | // ── EVENT task ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …xt/e2e/integration/workflow-execution-complete.spec.ts | 1068 | // ── SIMPLE worker task ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …xt/e2e/integration/workflow-execution-complete.spec.ts | 1176 | // ── START_WORKFLOW task ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/scheduler-definitions.spec.ts | 85 | // ── List / editor ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/scheduler-definitions.spec.ts | 172 | // ── Create / delete via UI ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/task-definitions.spec.ts | 23 | // ── Fixtures ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/task-definitions.spec.ts | 38 | // ── Tests ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/task-definitions.spec.ts | 147 | // ── Basic settings ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/task-definitions.spec.ts | 158 | // ── Rate limit settings ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/task-definitions.spec.ts | 166 | // ── Retry settings ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/task-definitions.spec.ts | 178 | // ── Timeout settings ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/task-definitions.spec.ts | 187 | // ── Input / Output keys ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/event-handlers.spec.ts | 54 | // ── List / editor ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/event-handlers.spec.ts | 98 | // ── Create / delete ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …t/e2e/integration/workflow-http-wait-terminate.spec.ts | 127 | // ── Helpers ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …t/e2e/integration/workflow-http-wait-terminate.spec.ts | 224 | // ── Tests ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 162 | // ── Workflow definitions ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 352 | // ── Setup / teardown ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 380 | // ── Tests: list page ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 417 | // ── Tests: Task tab — LLM_CHAT_COMPLETE ───────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 461 | // ── Tests: Task tab — LLM_TEXT_COMPLETE ───────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 500 | // ── Tests: Task tab — LLM_GENERATE_EMBEDDINGS ─────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 520 | // ── Tests: Task tab — multi-LLM workflow ──────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 570 | // ── Tests: Task tab — tool-calling workflow ───────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/llm-workflows.spec.ts | 595 | // ── Tests: execute LLM workflows ──────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/executions.spec.ts | 56 | // ── Helpers ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/executions.spec.ts | 108 | // ── Tests ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/workflows.spec.ts | 42 | // ── Fixtures ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/workflows.spec.ts | 81 | // ── Tests ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …src/pages/execution/AgentExecution/HumanInputPanel.tsx | 99 | // ─── Approval form ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …src/pages/execution/AgentExecution/HumanInputPanel.tsx | 250 | // ─── Manual agent selection form ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …src/pages/execution/AgentExecution/HumanInputPanel.tsx | 322 | // ─── Panel wrapper ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 37 | // ─── Types ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 61 | // ─── Tab keys ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 402 | // ─── Summary key-value row (matches Conductor's KeyValueTable style) ────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 458 | // ─── Status pill chip (matches Conductor's status badge) ────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 501 | // ─── Model display with provider icon ───────────────────────────────────────── | COMMENT |
| 275 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | main.py | 76 | "agentic_examples": "https://github.com/conductor-oss/javascript-sdk/tree/main/examples/agentic-workflows", | CODE |
| MEDIUM | ui-next/e2e/integration/workflows.spec.ts | 217 | // Matching this prefix confirms we have a fresh scaffold, not an existing def. | COMMENT |
| MEDIUM | ui-next/src/pages/execution/Execution.tsx | 442 | // (model/sub-agents/tools/guardrails), matching Conductor-Agents' | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 508 | // Tools/guardrails from the tools[] field | COMMENT |
| MEDIUM | docs/llms-full.txt | 1464 | ## 2. Test orchestration with mocked tasks | COMMENT |
| MEDIUM | docs/llms-full.txt | 3502 | # Microservice orchestration | COMMENT |
| MEDIUM | docs/llms-full.txt | 4521 | # AI & LLM orchestration recipes | COMMENT |
| MEDIUM | docs/llms-full.txt | 4572 | ### RAG pipeline with vector database (search + answer) | COMMENT |
| MEDIUM | docs/llms-full.txt | 5206 | # Anthropic (for RAG, extended thinking examples) | COMMENT |
| MEDIUM | docs/llms-full.txt | 5217 | # PostgreSQL Vector DB (for RAG examples) | COMMENT |
| MEDIUM | docs/documentation/clientsdks/python-sdk.md | 310 | # RAG pipeline | COMMENT |
| MEDIUM | docs/documentation/clientsdks/rust-sdk.md | 333 | # RAG pipeline | COMMENT |
| MEDIUM | docs/documentation/clientsdks/js-sdk.md | 402 | | [function-calling.ts](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/function-ca | CODE |
| MEDIUM⚡ | docs/documentation/clientsdks/js-sdk.md | 464 | See [examples/agentic-workflows/](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/) | CODE |
| MEDIUM⚡ | docs/documentation/clientsdks/js-sdk.md | 468 | | [llm-chat.ts](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/llm-chat.ts) | Auto | CODE |
| MEDIUM⚡ | docs/documentation/clientsdks/js-sdk.md | 469 | | [llm-chat-human-in-loop.ts](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/llm-c | CODE |
| MEDIUM⚡ | docs/documentation/clientsdks/js-sdk.md | 470 | | [function-calling.ts](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/function-ca | CODE |
| MEDIUM⚡ | docs/documentation/clientsdks/js-sdk.md | 471 | | [mcp-weather-agent.ts](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/mcp-weathe | CODE |
| MEDIUM⚡ | docs/documentation/clientsdks/js-sdk.md | 472 | | [multiagent-chat.ts](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/multiagent-c | CODE |
| MEDIUM | docs/documentation/clientsdks/js-sdk.md | 517 | | [Agentic Workflows](https://github.com/conductor-oss/javascript-sdk/tree/main/examples/agentic-workflows) | directory | CODE |
| MEDIUM | docs/documentation/clientsdks/java-sdk.md | 496 | Build AI agents where LLMs dynamically select and call Java workers as tools. All agentic examples live in [`AgenticExam | CODE |
| MEDIUM | docs/documentation/clientsdks/java-sdk.md | 510 | | [RagWorkflowExample.java](https://github.com/conductor-oss/java-sdk/blob/main/examples/old/src/main/java/io/orkes/cond | CODE |
| MEDIUM | docs/documentation/clientsdks/java-sdk.md | 511 | | [VectorDbExample.java](https://github.com/conductor-oss/java-sdk/blob/main/examples/old/src/main/java/io/orkes/conduct | CODE |
| MEDIUM | docs/documentation/clientsdks/java-sdk.md | 588 | | [All AI examples](https://github.com/conductor-oss/java-sdk/blob/main/examples/old/src/main/java/io/orkes/conductor/sd | CODE |
| MEDIUM | docs/documentation/clientsdks/java-sdk.md | 589 | | [RAG Workflow](https://github.com/conductor-oss/java-sdk/blob/main/examples/old/src/main/java/io/orkes/conductor/sdk/e | CODE |
| MEDIUM | docs/devguide/faq.md | 59 | ## Can Conductor orchestrate AI agents? | COMMENT |
| MEDIUM | docs/devguide/faq.md | 71 | ## Does Conductor support vector databases and RAG? | COMMENT |
| MEDIUM | docs/devguide/cookbook/files-api-usecase.md | 63 | ## 2. AI-Powered Knowledge Base Builder (RAG Pipeline) | COMMENT |
| MEDIUM | docs/devguide/cookbook/microservice-orchestration.md | 5 | # Microservice orchestration | COMMENT |
| MEDIUM | docs/devguide/cookbook/ai-llm.md | 6 | # AI & LLM orchestration recipes | COMMENT |
| MEDIUM | docs/devguide/cookbook/ai-llm.md | 57 | ### RAG pipeline with vector database (search + answer) | COMMENT |
| MEDIUM | docs/devguide/cookbook/ai-llm.md | 691 | # Anthropic (for RAG, extended thinking examples) | COMMENT |
| MEDIUM | docs/devguide/cookbook/ai-llm.md | 702 | # PostgreSQL Vector DB (for RAG examples) | COMMENT |
| MEDIUM | docs/devguide/ai/why-conductor.md | 162 | ## RAG pipelines — native vector database support | COMMENT |
| MEDIUM | docs/devguide/ai/why-conductor.md | 270 | ## Explicit orchestration, ordinary workers | COMMENT |
| MEDIUM | docs/devguide/ai/first-ai-agent.md | 14 | <a class="integration-action-card" href="#step-2-create-the-agentic-workflow-graph"> | CODE |
| MEDIUM | docs/devguide/ai/first-ai-agent.md | 90 | ## Step 2: Create the agentic workflow graph | COMMENT |
| MEDIUM | docs/devguide/ai/llm-orchestration.md | 5 | # LLM orchestration | COMMENT |
| MEDIUM | docs/devguide/ai/llm-orchestration.md | 110 | ### Example: RAG pipeline | COMMENT |
| MEDIUM | docs/devguide/ai/agent-evals.md | 107 | ## Test guardrails and side effects | COMMENT |
| MEDIUM | docs/devguide/ai/cookbook/agent-guardrails.md | 54 | | TypeScript | [`36-simple-agent-guardrails.ts`](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agen | CODE |
| MEDIUM | docs/devguide/ai/cookbook/rag-agent.md | 5 | # RAG Agent | COMMENT |
| MEDIUM | docs/devguide/concepts/tasks.md | 186 | ### Vector databases and RAG | COMMENT |
| MEDIUM | docs/devguide/how-tos/Workflows/testing-workflows.md | 27 | ## 2. Test orchestration with mocked tasks | COMMENT |
| MEDIUM | docs/architecture/json-native.md | 106 | Because the definition is inert, execution is deterministic. Given the same inputs, Conductor schedules the same tasks i | CODE |
| MEDIUM | …oross/conductor/common/metadata/agent/AgentConfig.java | 146 | * {@link Strategy#PLAN_EXECUTE}. The planner can be a simple agent or a multi-agent (e.g. | COMMENT |
| MEDIUM | ai/README.md | 1041 | ### 6. RAG (Retrieval Augmented Generation) | COMMENT |
| MEDIUM | ai/README.md | 1089 | #### Complete RAG Demo (Index + Search + Answer) | COMMENT |
| MEDIUM | ai/examples/README.md | 24 | # Anthropic (optional, for RAG examples) | COMMENT |
| MEDIUM | ai/examples/README.md | 36 | # PostgreSQL Vector DB (for RAG/embedding examples) | COMMENT |
| MEDIUM | ai/examples/README.md | 231 | ### 6. RAG (Basic) | COMMENT |
| MEDIUM | ai/examples/README.md | 245 | ### 7. RAG (Complete Demo) | COMMENT |
| MEDIUM | scripts/fetch-sdk-docs.py | 35 | ("csharp-sdk", "csharp-sdk.md", "C#", "csharp-examples", "Build Conductor workers in C#/.NET wi | CODE |
| MEDIUM | …lel_agents/3_5f58bc9d-7f9d-4b0b-ad8d-bc8c003f635c.json | 49 | "text" : "# Risk Analysis: Launching an AI-Powered Healthcare Diagnostic Tool in the U.S.\n\n## Executive assess | CODE |
| MEDIUM | …lel_agents/2_3ee63e99-45ce-4585-abdf-38fb0e7a5912.json | 49 | "text" : "# US Market Analysis: AI-Powered Healthcare Diagnostic Tool\n\n## 1. Market overview\n\nThe US is the | CODE |
| MEDIUM⚡ | …l_pipeline/2_c93f481a-10e0-4596-9728-1e38db998a8d.json | 11 | "text" : "The impact of AI agents on software development in 2025\n\nPrevious agent output:\n# Impact of AI Agents | CODE |
| MEDIUM⚡ | …l_pipeline/2_c93f481a-10e0-4596-9728-1e38db998a8d.json | 11 | "text" : "The impact of AI agents on software development in 2025\n\nPrevious agent output:\n# Impact of AI Agents | CODE |
| MEDIUM⚡ | …l_pipeline/1_3ba58b0c-cec6-47df-a2f1-d9804774d5f0.json | 49 | "text" : "# Impact of AI Agents on Software Development in 2025\n\n## Scope\n\nIn 2025, “AI agents” generally re | CODE |
| MEDIUM⚡ | …l_pipeline/1_3ba58b0c-cec6-47df-a2f1-d9804774d5f0.json | 49 | "text" : "# Impact of AI Agents on Software Development in 2025\n\n## Scope\n\nIn 2025, “AI agents” generally re | CODE |
| MEDIUM | …tegration/agent/AgentSpanRegistrationEndToEndTest.java | 125 | // ask_question" instruction in this agentic, multi-turn shape (it sometimes | COMMENT |
| 58 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 462 | new org.apache.kafka.common.errors.UnknownTopicOrPartitionException( | CODE |
| CRITICAL | …netflix/conductor/redis/dao/RedisExecutionDAOTest.java | 380 | new com.netflix.conductor.common.metadata.workflow.WorkflowTask(); | CODE |
| CRITICAL | …netflix/conductor/redis/dao/RedisExecutionDAOTest.java | 417 | new com.netflix.conductor.common.metadata.workflow.WorkflowTask(); | CODE |
| CRITICAL | …netflix/conductor/benchmark/ScriptEngineBenchmark.java | 254 | Object copy = com.netflix.conductor.core.events.ScriptEvaluator.deepCopy(input); | CODE |
| CRITICAL | …netflix/conductor/benchmark/ScriptEngineBenchmark.java | 255 | return com.netflix.conductor.core.events.ScriptEvaluator.eval(script, copy); | CODE |
| CRITICAL | …netflix/conductor/benchmark/ScriptEngineBenchmark.java | 294 | Object inputCopy = com.netflix.conductor.core.events.ScriptEvaluator.deepCopy(input); | CODE |
| CRITICAL⚡ | …netflix/conductor/benchmark/ScriptEngineBenchmark.java | 356 | v8 = com.caoccao.javet.interop.V8Host.getV8Instance().createV8Runtime(); | CODE |
| CRITICAL⚡ | …netflix/conductor/benchmark/ScriptEngineBenchmark.java | 360 | v8.setConverter(new com.caoccao.javet.interop.converters.JavetObjectConverter()); | CODE |
| CRITICAL⚡ | …netflix/conductor/benchmark/ScriptEngineBenchmark.java | 368 | Object inputCopy = com.netflix.conductor.core.events.ScriptEvaluator.deepCopy(input); | CODE |
| CRITICAL | …x/conductor/sqs/eventqueue/SQSObservableQueueTest.java | 78 | software.amazon.awssdk.services.sqs.model.Message.builder() | CODE |
| CRITICAL | …conductor/es8/config/ElasticSearchV8Configuration.java | 131 | return org.apache.http.ssl.SSLContexts.custom().loadTrustMaterial(trustStore, null).build(); | CODE |
| CRITICAL | …nductoross/conductor/ai/LLMHelperChatCompleteTest.java | 583 | org.junit.jupiter.api.Assertions.assertThrows( | CODE |
| CRITICAL | …s/conductor/ai/integration/AIModelIntegrationTest.java | 802 | com.google.auth.oauth2.GoogleCredentials.fromStream( | CODE |
| CRITICAL | …ductoross/conductor/ai/recording/LLMRecordingTest.java | 602 | org.conductoross.conductor.ai.model.ToolCall.builder() | CODE |
| CRITICAL | …ss/conductor/ai/providers/gemini/GeminiVertexTest.java | 152 | org.junit.jupiter.api.Assumptions.assumeTrue( | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 413 | org.conductoross.conductor.ai.model.Media.builder() | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 491 | org.conductoross.conductor.ai.model.Media.builder() | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 503 | org.conductoross.conductor.ai.model.Media.builder() | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 512 | org.conductoross.conductor.ai.model.Media.builder() | CODE |
| CRITICAL | …oross/conductor/ai/providers/gemini/api/GeminiApi.java | 75 | new com.netflix.conductor.common.config.ObjectMapperProvider().getObjectMapper(); | CODE |
| CRITICAL | …ss/conductor/ai/providers/stabilityai/StabilityAI.java | 146 | return org.springframework.ai.image.ImageOptionsBuilder.builder() | CODE |
| CRITICAL | …ctor/ai/providers/openai/OpenAIResponsesChatModel.java | 267 | new org.springframework.ai.chat.metadata.DefaultUsage( | CODE |
| CRITICAL | …/test/java/io/conductor/e2e/workflow/JavaSDKTests.java | 95 | @com.netflix.conductor.sdk.workflow.task.InputParam("name") String name) { | CODE |
| CRITICAL⚡ | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 53 | new com.netflix.conductor.common.metadata.workflow.WorkflowTask(); | CODE |
| CRITICAL⚡ | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 81 | new com.netflix.conductor.common.metadata.workflow.StartWorkflowRequest(); | CODE |
| CRITICAL⚡ | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 89 | org.junit.jupiter.api.Assertions.assertTrue( | CODE |
| CRITICAL | …/agentspan/runtime/service/AgentEventListenerTest.java | 357 | var definition = new com.netflix.conductor.common.metadata.workflow.WorkflowDef(); | CODE |
| CRITICAL | …x/conductor/rest/controllers/WorkflowResourceTest.java | 689 | List.of(new com.netflix.conductor.common.metadata.workflow.WorkflowTask())); | CODE |
| CRITICAL | …x/conductor/rest/controllers/WorkflowResourceTest.java | 963 | List.of(new com.netflix.conductor.common.metadata.workflow.WorkflowTask())); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 377 | // Step 1: Mock TopicDescription | COMMENT |
| LOW | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 395 | // Step 2: Mock Offsets | COMMENT |
| LOW⚡ | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 411 | // Step 3: Call the `size` method | COMMENT |
| LOW⚡ | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 414 | // Step 4: Verify the size is correctly calculated | COMMENT |
| LOW⚡ | ui-next/src/utils/utils.ts | 254 | // Step 1: Sort the array | COMMENT |
| LOW⚡ | ui-next/src/utils/utils.ts | 257 | // Step 2: Loop through the sorted array and find the missing numbers | COMMENT |
| LOW | ui-next/src/utils/utils.ts | 270 | // Step 3: Return the next missing number | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1952 | // Step 1: Apply * mapping to all tasks, if present. | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1966 | // Step 2: Override additional mappings. | COMMENT |
| LOW | …s/conductor/scheduler/redis/dao/RedisSchedulerDAO.java | 192 | // NOTE: This method performs multiple independent Redis commands without transactional | COMMENT |
| LOW | docs/documentation/clientsdks/go-sdk.md | 40 | ### Step 1: Creating the workflow by code | COMMENT |
| LOW | docs/documentation/clientsdks/go-sdk.md | 132 | ### Step 2: Creating the worker | COMMENT |
| LOW | docs/documentation/clientsdks/go-sdk.md | 151 | ### Step 3: Running the application | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 37 | ## Step 1: Build and deploy an agent with the SDK | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 90 | ## Step 2: Create the agentic workflow graph | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 142 | ## Step 3: Register and run the graph | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 85 | ### Step 1: Create the workflow | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 195 | ### Step 2: Create the compensation workflow | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 205 | ### Step 3: Write a custom worker | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 231 | ### Step 4: Run the workflow | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 248 | ### Step 5: Approve the review | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 263 | ### Step 6: Monitor and debug | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 291 | ### Step 7: Visualize | COMMENT |
| LOW | ai/CONTRIBUTING.md | 45 | ### Step 1: Create Provider Package | COMMENT |
| LOW | ai/CONTRIBUTING.md | 55 | ### Step 2: Implement AIModel Interface | COMMENT |
| LOW | ai/CONTRIBUTING.md | 93 | ### Step 3: Create Configuration Class | COMMENT |
| LOW | ai/CONTRIBUTING.md | 125 | ### Step 4: Create Properties Class | COMMENT |
| LOW | ai/CONTRIBUTING.md | 143 | ### Step 5: Add Tests | COMMENT |
| LOW | ai/CONTRIBUTING.md | 181 | ### Step 6: Add Video Generation Support (Optional) | COMMENT |
| LOW | ai/CONTRIBUTING.md | 263 | ### Step 7: Update Documentation | COMMENT |
| LOW | ai/CONTRIBUTING.md | 271 | ### Step 1: Create Config Class | COMMENT |
| LOW | ai/CONTRIBUTING.md | 295 | ### Step 2: Implement VectorDB Class | COMMENT |
| LOW | ai/CONTRIBUTING.md | 322 | ### Step 3: Register in VectorDBInstanceConfig | COMMENT |
| LOW | ai/CONTRIBUTING.md | 326 | ### Step 4: Add Integration Tests | COMMENT |
| LOW | ai/CONTRIBUTING.md | 350 | ### Step 1: Create Request Model | COMMENT |
| LOW | ai/CONTRIBUTING.md | 367 | ### Step 2: Create Worker Class | COMMENT |
| LOW | ai/CONTRIBUTING.md | 392 | ### Step 3: Add Task Tests | COMMENT |
| LOW⚡ | ai/examples/README.md | 132 | ### Step 1: Register a Workflow | COMMENT |
| LOW⚡ | ai/examples/README.md | 141 | ### Step 2: Execute the Workflow | COMMENT |
| LOW⚡ | ai/examples/README.md | 150 | ### Step 3: Check the Result | COMMENT |
| LOW⚡ | …toross/conductor/ai/video/VideoProviderMemoryTest.java | 43 | // Step 1: Store using fromBytes (optimized way) | COMMENT |
| LOW⚡ | …toross/conductor/ai/video/VideoProviderMemoryTest.java | 46 | // Step 2: Access bytes | COMMENT |
| LOW⚡ | …toross/conductor/ai/video/VideoProviderMemoryTest.java | 49 | // Step 3: Store in Media | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 65 | // Step 1: Parse markdown to AST | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 68 | // Step 2: Create PDF document | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 70 | // Step 3: Configure page size | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 73 | // Step 4: Set PDF metadata | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 76 | // Step 5: Create render context | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 89 | // Step 6: Render AST to PDF | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 94 | // Step 7: Close the last content stream | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 99 | // Step 8: Save to bytes | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 270 | ### Step 1: Update Dependencies (DONE) | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 277 | ### Step 2: Update Client Initialization | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 293 | ### Step 3: Migrate Query Builder Methods | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 312 | ### Step 4: Migrate Search Methods | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 326 | ### Step 5: Migrate Index/Update Methods | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 338 | ### Step 6: Migrate Delete Methods | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 344 | ### Step 7: Migrate Bulk Operations | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 355 | ### Step 8: Fix Sorting | COMMENT |
| LOW | os-persistence-v3/MIGRATION_GUIDE.md | 372 | ### Step 9: Update Exception Handling | COMMENT |
| 26 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 377 | // Step 1: Mock TopicDescription | COMMENT |
| LOW | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 395 | // Step 2: Mock Offsets | COMMENT |
| LOW⚡ | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 411 | // Step 3: Call the `size` method | COMMENT |
| LOW⚡ | …uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java | 414 | // Step 4: Verify the size is correctly calculated | COMMENT |
| LOW⚡ | ui-next/src/utils/utils.ts | 254 | // Step 1: Sort the array | COMMENT |
| LOW⚡ | ui-next/src/utils/utils.ts | 257 | // Step 2: Loop through the sorted array and find the missing numbers | COMMENT |
| LOW | ui-next/src/utils/utils.ts | 270 | // Step 3: Return the next missing number | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1952 | // Step 1: Apply * mapping to all tasks, if present. | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1966 | // Step 2: Override additional mappings. | COMMENT |
| LOW | …om/netflix/conductor/core/execution/tasks/DoWhile.java | 161 | // if we are here, the iteration is complete, and we need to check if there is a next | COMMENT |
| LOW⚡ | …toross/conductor/ai/video/VideoProviderMemoryTest.java | 43 | // Step 1: Store using fromBytes (optimized way) | COMMENT |
| LOW⚡ | …toross/conductor/ai/video/VideoProviderMemoryTest.java | 46 | // Step 2: Access bytes | COMMENT |
| LOW⚡ | …toross/conductor/ai/video/VideoProviderMemoryTest.java | 49 | // Step 3: Store in Media | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 65 | // Step 1: Parse markdown to AST | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 68 | // Step 2: Create PDF document | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 70 | // Step 3: Configure page size | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 73 | // Step 4: Set PDF metadata | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 76 | // Step 5: Create render context | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 89 | // Step 6: Render AST to PDF | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 94 | // Step 7: Close the last content stream | COMMENT |
| LOW⚡ | …ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java | 99 | // Step 8: Save to bytes | COMMENT |
| LOW⚡ | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 44 | // Step 1: Register a test task definition | COMMENT |
| LOW⚡ | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 50 | // Step 2: Register a workflow definition using this task | COMMENT |
| LOW | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 66 | // Step 3: Start a thread that constantly calls updateTaskDef | COMMENT |
| LOW⚡ | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 79 | // Step 4: Start a workflow while the updater thread is running | COMMENT |
| LOW⚡ | …t/java/io/conductor/e2e/workflow/ClearContextTest.java | 86 | // Step 5: Fetch the workflow and assert ownerApp is empty | COMMENT |
| LOW⚡ | …va/io/conductor/e2e/task/ConcurrentExecLimitTests.java | 244 | // Step 1: poll first task - should get exactly one because concurrentExecLimit=1. | COMMENT |
| LOW⚡ | …va/io/conductor/e2e/task/ConcurrentExecLimitTests.java | 252 | // Step 2: poll again - should be empty because B fails exceedsInProgressLimit and gets | COMMENT |
| LOW⚡ | …va/io/conductor/e2e/task/ConcurrentExecLimitTests.java | 262 | // Step 3: complete A. This frees the slot and (post-fix) releases B's postpone. | COMMENT |
| LOW⚡ | …va/io/conductor/e2e/task/ConcurrentExecLimitTests.java | 271 | // Step 4: B should now be pollable quickly. Allow 5s; pre-fix the bug forces ~60s. | COMMENT |
| LOW | …a/io/conductor/e2e/control/SubWorkflowInlineTests.java | 186 | // Step 1: wf_builder SIMPLE task is SCHEDULED — wait then complete it with the | COMMENT |
| LOW | …a/io/conductor/e2e/control/SubWorkflowInlineTests.java | 208 | // Step 2: The SUB_WORKFLOW task must become IN_PROGRESS, meaning the expression was | COMMENT |
| LOW | …a/io/conductor/e2e/control/SubWorkflowInlineTests.java | 227 | // Step 3: Iteration 1 (product = 1×5 = 5, 5 > 5 = false) runs entirely via system | COMMENT |
| LOW | …a/io/conductor/e2e/control/SubWorkflowInlineTests.java | 260 | // Step 4: After high_task completes, the DO_WHILE condition evaluates to false | COMMENT |
| LOW | …a/io/conductor/e2e/control/SubWorkflowInlineTests.java | 279 | // Step 5: Parent workflow completes once the SUB_WORKFLOW task is done. | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 75 | // Step 1: Parse SKILL.md frontmatter | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 83 | // Step 2: Auto-split large SKILL.md bodies into sections | COMMENT |
| LOW | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 101 | // Step 3: Build orchestrator AgentConfig | COMMENT |
| LOW | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 115 | // Step 4: Build sub-agents from *-agent.md files | COMMENT |
| LOW | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 166 | // Step 5: Build tools from scripts | COMMENT |
| LOW | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 195 | // Step 6: Build read_skill_file tool | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 243 | // Step 7: Build per-run workspace tools | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 248 | // Step 8: Wire cross-skill references | COMMENT |
| LOW | …r/ai/agentspan/runtime/normalizer/SkillNormalizer.java | 303 | // Step 9: Assemble | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/service/AgentEventListener.java | 478 | // Step 1: strip trailing __N (turn counter) | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/service/AgentEventListener.java | 481 | // Step 2: strip strategy-indexed prefixes | COMMENT |
| LOW | …r/ai/agentspan/runtime/service/AgentEventListener.java | 493 | // Step 3: strip leading N_ index prefix (e.g. "0_billing") | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | main.py | 1 | import html | COMMENT |
| LOW | conductor_server.sh | 1 | #!/bin/sh | COMMENT |
| LOW | ui/playwright/index.tsx | 1 | // Entry point for Playwright component testing. | COMMENT |
| LOW | ui/src/serviceWorker.js | 1 | // This optional code is used to register a service worker. | COMMENT |
| LOW | ui/src/setupTests.js | 1 | // jest-dom adds custom jest matchers for asserting on DOM nodes. | COMMENT |
| LOW | …m/netflix/conductor/sqlite/dao/SqliteIndexDAOTest.java | 581 | assertEquals("No results returned", 1, results.getResults().size()); | COMMENT |
| LOW | ui-next/src/monacoLoader.ts | 1 | import { loader } from "@monaco-editor/react"; | COMMENT |
| LOW | ui-next/src/index.ts | 41 | // Integration modal | COMMENT |
| LOW | ui-next/src/index.ts | 141 | } from "./shared/state/types"; | COMMENT |
| LOW | ui-next/src/utils/constants/regex.ts | 1 | export const CONTAIN_VARIABLE_SYNTAX_REGEX = /^(?=.*?[${}]{1}).*$/; | COMMENT |
| LOW | …xt/src/pages/queueMonitor/refresher/RefreshOptions.tsx | 21 | import { | COMMENT |
| LOW | …orPanel/TaskFormTab/forms/SimpleTaskForm/SampleCode.ts | 101 | COMMENT | |
| LOW | ui-next/src/pages/definition/state/action.ts | 661 | }); | COMMENT |
| LOW | …va/com/netflix/conductor/redislock/lock/RedisLock.java | 101 | // A Valid failure to acquire lock when another thread has acquired it returns false. | COMMENT |
| LOW | docker/docker-compose-ui-e2e.yaml | 1 | # Docker Compose stack for Playwright UI integration tests. | COMMENT |
| LOW | docker/server/bin/startup.sh | 1 | #!/bin/sh | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 21 | // public static final int PRODUCER_BATCH = 10; // make sure MSGS % PRODUCER_BATCH == 0 | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 41 | // public void setUp() { | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 61 | // | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 81 | // Thread.sleep(200); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 101 | // } | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 121 | // } catch (Exception e) { | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 141 | // | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 161 | // LOGGER.info("Unacked"); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 181 | // | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 201 | // | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 221 | // while (true) { | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 241 | // | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 261 | // LOGGER.error("Something went wrong with worker during poll", e); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 281 | // throw new RuntimeException(e); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 301 | // | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 321 | // LOGGER.info("Pushed ALL"); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 341 | // E.getWorkflowsByCorrelationId("abcd", "2", true).size()); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 361 | // Thread.sleep(COMPLETION_MONITOR_DELAY); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 381 | // } | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 401 | // wf.setTasks(randomTasks); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 421 | // }).collect(Collectors.toList()); | COMMENT |
| LOW | …ix/conductor/postgres/performance/PerformanceTest.java | 441 | // try { | COMMENT |
| LOW | …etflix/conductor/core/execution/tasks/DoWhileTest.java | 1401 | assertFalse( | COMMENT |
| LOW | …ross/conductor/model/WorkflowSignalReturnStrategy.java | 41 | // made to notify with | COMMENT |
| LOW | ai/src/test/resources/ai-test-env.sh | 1 | #!/bin/bash | COMMENT |
| LOW | ai/src/test/resources/ai-test-env.sh | 21 | export ANTHROPIC_API_KEY="your-anthropic-api-key" | COMMENT |
| LOW | ai/src/test/resources/ai-test-env.sh | 41 | # export MISTRAL_BASE_URL="https://api.mistral.ai" | COMMENT |
| LOW | ai/src/test/resources/ai-test-env.sh | 61 | export COHERE_API_KEY="your-cohere-api-key" | COMMENT |
| LOW | …rc/test/resources/a2a/durable-demo/run-durable-demo.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …rc/test/resources/a2a/interop-demo/run-interop-demo.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …toross/conductor/ai/vectordb/PostgresVectorDBTest.java | 321 | // Verify query operator for cosine (<=>) | COMMENT |
| LOW | …ai/mapper/AIModelTaskMapperPreviousResponseIdTest.java | 181 | // Regression: getHistory() used to be skipped entirely when | COMMENT |
| LOW | …/conductor/ai/tasks/mapper/ChatCompleteTaskMapper.java | 181 | // (b) the provider declares it doesn't accept assistant-message prefill | COMMENT |
| LOW | .github/workflows/publish-next.yaml | 1 | name: Publish Next (ui-next) | COMMENT |
| LOW | .github/workflows/publish.yml | 41 | env: | COMMENT |
| LOW | .github/workflows/update-ui-snapshots.yml | 1 | # Regenerates the Playwright reference snapshots for ui-next on demand. | COMMENT |
| LOW | .github/workflows/review-policy.yml | 1 | name: review-policy | COMMENT |
| LOW | …nductor/grpc/server/service/HealthServiceImplTest.java | 21 | // @Rule | COMMENT |
| LOW | …nductor/grpc/server/service/HealthServiceImplTest.java | 41 | // | COMMENT |
| LOW | …nductor/grpc/server/service/HealthServiceImplTest.java | 61 | // addService(serverName, healthyService); | COMMENT |
| LOW | …nductor/grpc/server/service/HealthServiceImplTest.java | 81 | // when(hca.check()).thenReturn(hcsf); | COMMENT |
| LOW | …/test/java/io/conductor/e2e/task/RetryPolicyTests.java | 721 | // responseTimeout=3s, the sweeper would not re-evaluate until ~30s, missing | COMMENT |
| LOW | …t/java/io/conductor/e2e/task/LLMChatCompleteTests.java | 541 | + OPENAI_REASONING_MODEL | COMMENT |
| LOW | …t/java/io/conductor/e2e/task/LLMChatCompleteTests.java | 601 | // possible (turn 3 → turn 2's id, etc.). Tested at the unit layer too, but | COMMENT |
| 21 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | ai/README.md | 736 | export OPENAI_API_KEY=sk-your-api-key | CODE |
| HIGH⚡ | ai/README.md | 737 | export ANTHROPIC_API_KEY=sk-ant-your-api-key | CODE |
| HIGH⚡ | ai/README.md | 744 | $env:OPENAI_API_KEY = "sk-your-api-key" | CODE |
| HIGH⚡ | ai/README.md | 745 | $env:ANTHROPIC_API_KEY = "sk-ant-your-api-key" | CODE |
| HIGH | ai/README.md | 760 | -e OPENAI_API_KEY=sk-your-api-key \ | CODE |
| HIGH | ai/README.md | 761 | -e ANTHROPIC_API_KEY=sk-ant-your-api-key \ | CODE |
| HIGH | ai/README.md | 786 | OPENAI_API_KEY=sk-your-api-key | CODE |
| HIGH | ai/README.md | 787 | ANTHROPIC_API_KEY=sk-ant-your-api-key | CODE |
| HIGH | ai/README.md | 804 | -e GEMINI_API_KEY=your-api-key \ | CODE |
| HIGH | …ross/conductor/ai/vectordb/VectorDBInstanceConfig.java | 44 | * apiKey: "your-api-key" | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ui/src/data/workflow.js | 142 | export function useWorkflowNamesAndVersions() { | CODE |
| LOW | ui/src/data/scheduler.js | 71 | export function useSchedulerExecutionSearch(searchObj) { | CODE |
| LOW | ui-next/e2e/integration/api-client.ts | 430 | export async function searchSchedulerExecutions(params: { | CODE |
| LOW | ui-next/e2e/integration/api-client.ts | 451 | export async function waitForSchedulerExecution( | CODE |
| LOW | ui-next/e2e/integration/helpers.ts | 69 | export async function waitForExecutionDiagramReady(page: Page): Promise<void> { | CODE |
| LOW | ui-next/e2e/integration/helpers.ts | 101 | export async function setDiagramSnapshotViewport(page: Page): Promise<void> { | CODE |
| LOW | ui-next/e2e/integration/helpers.ts | 120 | export async function expectMainContentScreenshot( | CODE |
| LOW | …xt/e2e/integration/workflow-execution-complete.spec.ts | 317 | async function expectExecutionStatusChip( | CODE |
| LOW | …t/e2e/integration/workflow-http-wait-terminate.spec.ts | 136 | async function expectExecutionStatusChip( | CODE |
| LOW | ui-next/e2e/integration/llm-workflows.spec.ts | 67 | async function expectExecutionStatusChip( | CODE |
| LOW | ui-next/e2e/integration/llm-workflows.spec.ts | 136 | async function runLlmWorkflowToCompletion( | CODE |
| LOW | ui-next/e2e/helpers/mockApi.ts | 299 | export async function mockSchemaReferencingTaskDef(page: Page): Promise<void> { | CODE |
| LOW | ui-next/e2e/helpers/mockApi.ts | 330 | export async function mockMissingSchemaRegistry(page: Page): Promise<void> { | CODE |
| LOW | ui-next/src/utils/helpers.ts | 245 | export function replacePathPlaceholdersToWorkflowInput(path: string): string { | CODE |
| LOW | ui-next/src/utils/workflow.ts | 327 | export function scanTasksForDependenciesInTasks(tasks: CommonTaskDef[]) { | CODE |
| LOW | ui-next/src/utils/workflow.ts | 378 | export function scanTasksForDependenciesInWorkflow(workflow: WorkflowDef) { | CODE |
| LOW | ui-next/src/utils/resolveDefaultHomePath.ts | 32 | export function findFirstNavigableSidebarPath( | CODE |
| LOW | ui-next/src/utils/agentMetadata.ts | 222 | export async function resolveAgentSnapshotsInWorkflow( | CODE |
| LOW | ui-next/src/utils/query.ts | 539 | export function useWorkflowNamesAndVersions(): Map<string, number[]> { | CODE |
| LOW | ui-next/src/utils/query.ts | 548 | export function useWorkflowDefsByVersions({ | CODE |
| LOW | ui-next/src/components/features/auth/silentRefresh.ts | 14 | export function hasRefreshPermanentlyFailed(): boolean { | CODE |
| LOW | …ts/features/flow/components/shapes/TaskCard/helpers.ts | 13 | export function dowhileHasAllIterationsInOutput( | CODE |
| LOW | …ts/features/flow/components/shapes/TaskCard/helpers.ts | 32 | export function dowhileHasSummarizedIterations( | CODE |
| LOW | ui-next/src/pages/scheduler/__tests__/hooks.test.ts | 542 | function buildWorkflowDefByVersions( | CODE |
| LOW | ui-next/src/pages/scheduler/hooks/useCronExpression.ts | 23 | function calculateLastDayOffsetMatches( | CODE |
| LOW | ui-next/src/pages/agent/guideMarkdown.ts | 3 | export function resolveAgentGuideMarkdown(markdown: string) { | CODE |
| LOW | ui-next/src/pages/runWorkflow/runWorkflowUtils.ts | 139 | export function getTemplateFromInputParams(inputParamsArray: any) { | CODE |
| LOW | …rPanel/TaskFormTab/forms/JOINTaskForm/JOINTaskForm.tsx | 87 | async function setPossibleTaskReferencesAsync( | CODE |
| LOW | ui-next/src/pages/execution/helpers.ts | 60 | export function findTaskFromExecutionStatusMapById( | CODE |
| LOW | …/pages/execution/RightPanel/doWhileIterationHelpers.ts | 12 | export function deriveFallbackIterationStatus( | CODE |
| LOW | …/pages/execution/AgentExecution/agentExecutionUtils.ts | 378 | function sortTasksByWorkflowSequence(tasks: ExecutionTask[]): ExecutionTask[] { | CODE |
| LOW | …/pages/execution/AgentExecution/agentExecutionUtils.ts | 398 | function parallelGroupsByTaskReference( | CODE |
| LOW | …/pages/execution/AgentExecution/agentExecutionUtils.ts | 722 | function transformChainWorkflowToAgentRun( | CODE |
| LOW | …/pages/execution/AgentExecution/agentExecutionUtils.ts | 931 | export function transformWorkflowExecutionToAgentRun( | CODE |
| LOW | docs/overrides/main.html | 100 | function applyFirstAgentNavigation() { | CODE |
| LOW | docs/devguide/ai/agent-evals.md | 178 | def test_weather_routes_to_the_right_tool(mock_agent_run, event): | CODE |
| LOW | scripts/check-workflows-docs.py | 108 | def check_compatibility_routes() -> None: | CODE |
| LOW | scripts/test_generate_llm_context.py | 20 | def test_expands_nested_repository_root_includes(self) -> None: | CODE |
| LOW | scripts/test_generate_llm_context.py | 34 | def test_rejects_missing_include(self) -> None: | CODE |
| LOW | scripts/test_generate_llm_context.py | 42 | def test_rejects_out_of_root_include(self) -> None: | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 66 | def test_completed_workflows_pass(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 69 | def test_guardrail_rejection_passes_without_sdk_metadata(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 73 | def test_worker_guardrail_rejection_passes(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 80 | def test_unrelated_failure_is_not_a_guardrail_rejection(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 83 | def test_failed_llm_task_fails_even_with_guardrail_output(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 88 | def test_rejection_followed_by_an_unrelated_failure_fails(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 93 | def test_termination_must_reference_the_rejecting_guardrail(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 98 | def test_missing_or_incomplete_termination_fails(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 106 | def test_non_rejecting_decisions_fail(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 113 | def test_unfinished_and_other_terminal_states_fail(self): | CODE |
| LOW⚡ | .github/actions/check-playback/test_check_playback.py | 120 | def test_unrelated_failure_after_first_page_fails(self): | CODE |
| LOW | .github/actions/check-playback/test_check_playback.py | 131 | def test_incomplete_search_page_fails(self): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/pages/execution/AgentExecution/agentExecutionUtils.ts | 963 | // Build set of guardrail function names from agentDef for robust detection | COMMENT |
| MEDIUM | .github/workflows/ci.yml | 32 | # jobs that need more (e.g. checks: write to publish test-result checks) elevate | COMMENT |
| MEDIUM | …lel_agents/1_467940fd-fdcc-4f77-89a9-ac5db5ad77a4.json | 49 | "text" : "Launching an AI-powered healthcare diagnostic tool in the United States typically involves **medical-d | CODE |
| MEDIUM | …lel_agents/3_5f58bc9d-7f9d-4b0b-ad8d-bc8c003f635c.json | 49 | "text" : "# Risk Analysis: Launching an AI-Powered Healthcare Diagnostic Tool in the U.S.\n\n## Executive assess | CODE |
| MEDIUM | …o_parallel/5_6affdf06-c067-4aa9-805d-0dd4a6562ec8.json | 49 | "text" : "# Deep analysis: Entering the AI healthcare market\n\n## Executive assessment\n\nThe AI healthcare mar | CODE |
| MEDIUM⚡ | …l_pipeline/2_c93f481a-10e0-4596-9728-1e38db998a8d.json | 11 | "text" : "The impact of AI agents on software development in 2025\n\nPrevious agent output:\n# Impact of AI Agents | CODE |
| MEDIUM⚡ | …l_pipeline/2_c93f481a-10e0-4596-9728-1e38db998a8d.json | 11 | "text" : "The impact of AI agents on software development in 2025\n\nPrevious agent output:\n# Impact of AI Agents | CODE |
| MEDIUM | …l_pipeline/2_c93f481a-10e0-4596-9728-1e38db998a8d.json | 49 | "text" : "# How AI Agents Are Changing Software Development in 2025\n\nAI is no longer limited to suggesting the | CODE |
| MEDIUM⚡ | …l_pipeline/1_3ba58b0c-cec6-47df-a2f1-d9804774d5f0.json | 49 | "text" : "# Impact of AI Agents on Software Development in 2025\n\n## Scope\n\nIn 2025, “AI agents” generally re | CODE |
| MEDIUM⚡ | …l_pipeline/1_3ba58b0c-cec6-47df-a2f1-d9804774d5f0.json | 49 | "text" : "# Impact of AI Agents on Software Development in 2025\n\n## Scope\n\nIn 2025, “AI agents” generally re | CODE |
| MEDIUM | …l_pipeline/3_50097ced-b000-4b57-822d-62ed8f3d9fab.json | 11 | "text" : "The impact of AI agents on software development in 2025\n\nPrevious agent output:\n# How AI Agents Are C | CODE |
| MEDIUM | …l_pipeline/3_50097ced-b000-4b57-822d-62ed8f3d9fab.json | 49 | "text" : "# The Impact of AI Agents on Software Development in 2025\n\nAI is no longer limited to suggesting the | CODE |
| MEDIUM | …java/io/conductor/e2e/workflow/WorkflowRerunTests.java | 5714 | // to be robust to convention drift across versions. | COMMENT |
| MEDIUM | agentspan/src/test/resources/skills/large-skill.json | 4 | "skillMd": "---\nname: large-skill\ndescription: A large skill for testing section splitting.\n---\n# Conductor Skill\ | CODE |
| MEDIUM | …r/ai/agentspan/runtime/controller/AgentController.java | 62 | * /dg #6: compile a plan against a PLAN_EXECUTE harness config and return the resulting | COMMENT |
| MEDIUM | …nductor/ai/agentspan/runtime/service/AgentService.java | 117 | * /dg #6: compile a plan against a PLAN_EXECUTE harness config and return the resulting | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | …l_pipeline/2_c93f481a-10e0-4596-9728-1e38db998a8d.json | 11 | "text" : "The impact of AI agents on software development in 2025\n\nPrevious agent output:\n# Impact of AI Agents | CODE |
| HIGH | …l_pipeline/2_c93f481a-10e0-4596-9728-1e38db998a8d.json | 49 | "text" : "# How AI Agents Are Changing Software Development in 2025\n\nAI is no longer limited to suggesting the | CODE |
| HIGH⚡ | …l_pipeline/1_3ba58b0c-cec6-47df-a2f1-d9804774d5f0.json | 49 | "text" : "# Impact of AI Agents on Software Development in 2025\n\n## Scope\n\nIn 2025, “AI agents” generally re | CODE |
| HIGH | …l_pipeline/3_50097ced-b000-4b57-822d-62ed8f3d9fab.json | 11 | "text" : "The impact of AI agents on software development in 2025\n\nPrevious agent output:\n# How AI Agents Are C | CODE |
| HIGH | …l_pipeline/3_50097ced-b000-4b57-822d-62ed8f3d9fab.json | 49 | "text" : "# The Impact of AI Agents on Software Development in 2025\n\nAI is no longer limited to suggesting the | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …FormTab/forms/LLMInstructionsWithPromptPicker.test.tsx | 243 | "placeholder", | CODE |
| LOW | …uctor/postgres/storage/PostgresPayloadStorageTest.java | 57 | "Lorem Ipsum is simply dummy text of the printing and typesetting industry." | CODE |
| LOW | …uctor/postgres/storage/PostgresPayloadStorageTest.java | 58 | + " Lorem Ipsum has been the industry's standard dummy text ever since the 1500s."; | CODE |
| LOW | docs/documentation/configuration/taskdef.md | 196 | "ownerEmail": "foo@bar.com", | CODE |
| LOW | …on/configuration/workflowdef/systemtasks/human-task.md | 157 | "approvedBy": "user@example.com", | CODE |
| LOW | docs/wmq/workflow-message-queue-architecture.md | 74 | "approvedBy": "user@example.com" | CODE |
| LOW | …or/test/integration/http/SchedulerIntegrationTest.java | 455 | taskDef.put("ownerEmail", "test@test.com"); | CODE |
| LOW | …or/test/integration/http/SchedulerIntegrationTest.java | 463 | wfDef.put("ownerEmail", "test@test.com"); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ide/ai/cookbook/assets/deploy_local_cookbook_agents.py | 13 | CODE | |
| LOW | scripts/check-workflows-docs.py | 4 | CODE | |
| LOW | scripts/test_generate_llm_context.py | 4 | CODE | |
| LOW | scripts/check_ai_cookbook.py | 4 | CODE | |
| LOW | scripts/capture_cookbook_verification.py | 9 | CODE | |
| LOW | scripts/capture_cookbook_verification.py | 13 | CODE | |
| LOW | scripts/generate-llm-context.py | 4 | CODE | |
| LOW | scripts/validate_cookbook_ai_examples.py | 9 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | docs/devguide/cookbook/assets/saga_stub_service.py | 42 | CODE | |
| LOW | scripts/check-workflows-docs.py | 41 | CODE | |
| LOW | scripts/check-workflows-docs.py | 54 | CODE | |
| LOW | scripts/check_ai_cookbook.py | 34 | CODE | |
| LOW | scripts/check_ai_cookbook.py | 41 | CODE | |
| LOW | .github/actions/start-playback-services/http_fixture.py | 12 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | scripts/fetch-sdk-docs.py | 50 | except Exception: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | conductor_server.sh | 5 | # Usage: | COMMENT |
| LOW | ui-next/scripts/run-integration-e2e.sh | 5 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/fetch-sdk-docs.py | 50 | except Exception: | CODE |
| LOW | scripts/fetch-sdk-docs.py | 62 | except Exception as e: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …lix/conductor/cassandra/dao/CassandraExecutionDAO.java | 355 | // TODO: implement for query against multiple shards | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | ai/src/test/resources/ai-test-env.sh | 33 | # Set path to your service account JSON key file | COMMENT |