Conductor is an event driven agentic workflow engine providing durable and highly resilient execution engine for applications and AI Agents
This report presents the forensic synthetic code analysis of conductor-oss/conductor, a Java project with 31,996 GitHub stars. SynthScan v2.0 examined 568,584 lines of code across 3355 source files, recording 669 pattern matches distributed across 14 syntactic categories. The overall adjusted score of 3.4 places this repository in the Likely human-written band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 669 distinct pattern matches across 14 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. 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 diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| 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 | 64 | // ─── Filter form ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/workflow-execution-search-filters.spec.ts | 181 | // ─── SQL toggle mode ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 16 | // ── Types ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 60 | // ── Helpers ─────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 82 | // ── Workflow definitions ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 109 | // ── Workflow executions ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/api-client.ts | 160 | // ── Task definitions ────────────────────────────────────────────────────────── | 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/executions.spec.ts | 50 | // ── Helpers ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/executions.spec.ts | 66 | // ── Tests ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/workflows.spec.ts | 40 | // ── Fixtures ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/e2e/integration/workflows.spec.ts | 55 | // ── 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 | 33 | // ─── Types ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 55 | // ─── Tab keys ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 62 | // ─── JSON editor viewer (Monaco, fills available height) ───────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 90 | // ─── Markdown renderer ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 152 | // ─── Smart content renderer (text/markdown/JSON) ────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 200 | // ─── Summary key-value row (matches Conductor's KeyValueTable style) ────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 256 | // ─── Status pill chip (matches Conductor's status badge) ────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 299 | // ─── Model display with provider icon ───────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 317 | // ─── Context condensation banner ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 360 | // ─── Agent definition section ───────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 975 | // ─── Parallel run selector ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 1139 | // ─── Group detail panel (parallel agents / tool calls) ──────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 1512 | // ─── Lazy-fetch sub-agent definition (model + agentDef) ────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 1561 | // ─── Summary tab content per node kind ────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 2106 | // ─── Resolve input value for a node ───────────────────────────────────────── | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 2169 | // ─── Main panel ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 32 | // ─── Constants ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 40 | // ─── Strategy colours ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 58 | // ─── Types ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 78 | // ─── Helpers ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 109 | // ─── Gate (decision / conditional) card ────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 215 | // ─── Node card ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 435 | // ─── Reaflow node wrapper ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 461 | // ─── Build diagram from agentDef ───────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 524 | // ── Root agent node ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 551 | // ── Sub-agents: chain for sequential, fan-out otherwise ────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 667 | // ── Tools / HTTP / MCP / RAG ───────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 691 | // ─── Zoom controls (mirrors AgentExecutionDiagram's DiagramControls) ────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 755 | // ─── Main diagram canvas ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 962 | // ─── Public wrapper ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/src/pages/execution/AgentExecution/EventRow.tsx | 19 | // ─── Visual config ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/src/pages/execution/AgentExecution/EventRow.tsx | 111 | // ─── Detail renderer ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/src/pages/execution/AgentExecution/EventRow.tsx | 182 | // ─── Context condensation separator ──────────────────────────────────────── | COMMENT |
| MEDIUM | ui-next/src/pages/execution/AgentExecution/EventRow.tsx | 220 | // ─── Main component ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ges/execution/AgentExecution/AgentExecutionDiagram.tsx | 50 | // ─── Constants ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ges/execution/AgentExecution/AgentExecutionDiagram.tsx | 56 | // ─── Types ──────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …ges/execution/AgentExecution/AgentExecutionDiagram.tsx | 140 | // ─── CardLabel-matching type badge (same CSS as CardLabel.jsx) ───────────────── | COMMENT |
| MEDIUM | …ges/execution/AgentExecution/AgentExecutionDiagram.tsx | 163 | // ─── Small status badge (20×20 instead of CardStatusBadge's 30×30) ────────── | COMMENT |
| MEDIUM | …ges/execution/AgentExecution/AgentExecutionDiagram.tsx | 224 | // ─── Node card — all nodes use white TaskCard styling ───────────────────────── | COMMENT |
| 232 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 | …i/agentspan/runtime/service/AgentServiceTokenTest.java | 100 | new com.netflix.conductor.common.metadata.workflow.WorkflowDef(); | CODE |
| CRITICAL | …i/agentspan/runtime/service/AgentServiceTokenTest.java | 150 | new com.netflix.conductor.common.metadata.workflow.WorkflowDef(); | CODE |
| CRITICAL | …/agentspan/runtime/service/AgentEventListenerTest.java | 60 | var def = new com.netflix.conductor.common.metadata.workflow.WorkflowDef(); | CODE |
| CRITICAL | …x/conductor/sqs/eventqueue/SQSObservableQueueTest.java | 78 | software.amazon.awssdk.services.sqs.model.Message.builder() | CODE |
| CRITICAL | …conductor/es8/config/ElasticSearchV8Configuration.java | 130 | 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 | …ss/conductor/ai/providers/gemini/GeminiVertexTest.java | 147 | org.junit.jupiter.api.Assumptions.assumeTrue( | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 432 | org.conductoross.conductor.ai.model.Media.builder() | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 509 | org.conductoross.conductor.ai.model.Media.builder() | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 521 | org.conductoross.conductor.ai.model.Media.builder() | CODE |
| CRITICAL | …main/java/org/conductoross/conductor/ai/LLMHelper.java | 530 | 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 | …x/conductor/rest/controllers/WorkflowResourceTest.java | 656 | List.of(new com.netflix.conductor.common.metadata.workflow.WorkflowTask())); | CODE |
| CRITICAL | …x/conductor/rest/controllers/WorkflowResourceTest.java | 930 | List.of(new com.netflix.conductor.common.metadata.workflow.WorkflowTask())); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | ui-next/e2e/integration/workflows.spec.ts | 185 | // Matching this prefix confirms we have a fresh scaffold, not an existing def. | COMMENT |
| MEDIUM | ui-next/src/pages/execution/Execution.tsx | 474 | // (model/sub-agents/tools/guardrails), matching AgentSpan's | COMMENT |
| MEDIUM | …rc/pages/execution/AgentExecution/AgentDetailPanel.tsx | 777 | // Read guardrails from both old and new field names | COMMENT |
| MEDIUM | …pages/execution/AgentExecution/AgentDefinitionView.tsx | 478 | // Tools/guardrails from the tools[] field | COMMENT |
| MEDIUM | …/agentspan/runtime/service/PlanAndCompileTaskTest.java | 962 | // Tool-level guardrails — wrap SIMPLE with format → check → SWITCH | COMMENT |
| MEDIUM | …/agentspan/runtime/service/PlanAndCompileTaskTest.java | 967 | // Counter-test: when the tool config has no guardrails, the SIMPLE | COMMENT |
| MEDIUM | …/agentspan/runtime/service/PlanAndCompileTaskTest.java | 1177 | // Two guardrails on one tool ⇒ nested SWITCH gates. Outer gate's | COMMENT |
| MEDIUM | …r/ai/agentspan/runtime/compiler/AgentCompilerTest.java | 551 | // Inside loop: ctx_inject + before_model + LLM + after_model + guardrails + tool_router + | COMMENT |
| MEDIUM | …or/ai/agentspan/runtime/compiler/ToolCompilerTest.java | 300 | // No guardrails -> empty refs | COMMENT |
| MEDIUM | …or/ai/agentspan/runtime/compiler/ToolCompilerTest.java | 340 | // First task: format_tool_calls (guardrails come first) | COMMENT |
| MEDIUM | …agentspan/runtime/compiler/MultiAgentCompilerTest.java | 1994 | // RETRY/FIX/HUMAN guardrails collapse to TERMINATE in plan mode; | COMMENT |
| MEDIUM | …/agentspan/runtime/compiler/GuardrailCompilerTest.java | 190 | .position("input") // position is not filtered for tool guardrails | CODE |
| MEDIUM⚡ | …/agentspan/runtime/compiler/GuardrailCompilerTest.java | 202 | // Ref name uses "_tool" prefix to avoid collision with agent-level guardrails | COMMENT |
| MEDIUM⚡ | …/agentspan/runtime/compiler/GuardrailCompilerTest.java | 210 | // Tool guardrails with position="input" should still compile | COMMENT |
| MEDIUM⚡ | …/agentspan/runtime/compiler/GuardrailCompilerTest.java | 211 | // (unlike agent guardrails which filter to output only) | COMMENT |
| MEDIUM | …/agentspan/runtime/compiler/GuardrailCompilerTest.java | 224 | // compileGuardrailTasks filters out input guardrails | COMMENT |
| MEDIUM | …/agentspan/runtime/compiler/GuardrailCompilerTest.java | 288 | // Custom guardrails can return on_fail=fix directly; regex/llm scripts | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/normalizer/OpenAINormalizer.java | 260 | // OpenAI guardrails have a "position" that's either "input" or "output" | COMMENT |
| MEDIUM | …/agentspan/runtime/normalizer/GoogleADKNormalizer.java | 239 | // ADK agent via AdkBridge.agentBuilder(...).guardrails(...). Without | COMMENT |
| MEDIUM | …/agentspan/runtime/normalizer/GoogleADKNormalizer.java | 240 | // this, the SDK ships `guardrails: [...]` in the rawConfig but the | COMMENT |
| MEDIUM⚡ | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 124 | // Full tool configs (with guardrails). Built into a name→ToolConfig | COMMENT |
| MEDIUM⚡ | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 126 | // input guardrails. Without this, plan-mode tool calls bypass the | COMMENT |
| MEDIUM⚡ | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 127 | // guardrails the LLM-loop path enforces — same call site, same tool, | COMMENT |
| MEDIUM | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 620 | // Guardrail wrap: if the tool declares input/output guardrails, | COMMENT |
| MEDIUM | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 623 | // this, plan-mode tool calls bypass the guardrails the | COMMENT |
| MEDIUM⚡ | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2249 | // Planner (agentic LLM) → extract JSON fence → compile plan to dynamic | COMMENT |
| MEDIUM⚡ | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2251 | // run fallback agent (agentic LLM, bounded turns). | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 223 | // Wrap with guardrails if needed | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2279 | // wraps each emitted SIMPLE task with the tool's input guardrails | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2410 | // ── 2. Run planner (agentic sub-workflow) ──────────────────── | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2579 | // wrote and is more useful context when the agentic recovery loop | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2690 | // Full tool configs (with guardrails). PAC uses these to wrap each | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2691 | // emitted SIMPLE task with the tool's input guardrails — without | COMMENT |
| MEDIUM | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2706 | // the agentic fallback exists to recover from. Only TERMINATE when | COMMENT |
| MEDIUM | …r/ai/agentspan/runtime/compiler/GuardrailCompiler.java | 81 | // Filter to output guardrails only | COMMENT |
| MEDIUM | …r/ai/agentspan/runtime/compiler/GuardrailCompiler.java | 112 | // Tool guardrails use a fixed iteration ref since retry is handled by the outer DoWhile | COMMENT |
| MEDIUM | …r/ai/agentspan/runtime/compiler/GuardrailCompiler.java | 371 | // - fix → custom guardrails return ``fix`` directly; regex/llm | COMMENT |
| MEDIUM | …ductor/ai/agentspan/runtime/compiler/ToolCompiler.java | 1551 | // Tool guardrails (before approval, before fork) | COMMENT |
| MEDIUM | …ductor/ai/agentspan/runtime/compiler/ToolCompiler.java | 1942 | // Tool guardrails (before approval, before fork) | COMMENT |
| MEDIUM | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 280 | // Check for output guardrails | COMMENT |
| MEDIUM | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 297 | // Guarded path: LLM + guardrails in DoWhile loop | COMMENT |
| MEDIUM | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 305 | // Compile guardrails inside loop | COMMENT |
| MEDIUM | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 573 | // Output guardrails (inside loop, after LLM) | COMMENT |
| MEDIUM | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 609 | // Wire all retry refs (agent + tool guardrails) into LLM participants | COMMENT |
| MEDIUM | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 973 | // Output guardrails | COMMENT |
| MEDIUM | docs/index.md | 241 | <p>Conductor is the only open source workflow engine with native LLM task types for 14+ providers, built-in MCP in | CODE |
| MEDIUM | docs/documentation/clientsdks/csharp-sdk.md | 2 | description: "Build Conductor workers in C#/.NET with dependency injection, workflow management, and task polling." | CODE |
| MEDIUM | docs/documentation/clientsdks/python-sdk.md | 351 | # RAG pipeline | COMMENT |
| MEDIUM | docs/documentation/clientsdks/index.md | 2 | description: "Conductor SDKs for Java, Python, Go, JavaScript, C#, Ruby, and Rust — build workflow as code and task work | CODE |
| MEDIUM | docs/documentation/clientsdks/rust-sdk.md | 371 | # RAG pipeline | COMMENT |
| MEDIUM | docs/documentation/clientsdks/js-sdk.md | 393 | | [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 | 455 | See [examples/agentic-workflows/](https://github.com/conductor-oss/javascript-sdk/blob/main/examples/agentic-workflows/) | CODE |
| MEDIUM⚡ | docs/documentation/clientsdks/js-sdk.md | 459 | | [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 | 460 | | [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 | 461 | | [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 | 462 | | [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 | 463 | | [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 | 546 | | [Agentic Workflows](https://github.com/conductor-oss/javascript-sdk/tree/main/examples/agentic-workflows) | directory | CODE |
| MEDIUM | docs/documentation/clientsdks/java-sdk.md | 434 | 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 | 448 | | [RagWorkflowExample.java](https://github.com/conductor-oss/java-sdk/blob/main/examples/old/src/main/java/io/orkes/cond | CODE |
| 27 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 | 238 | // Step 1: Sort the array | COMMENT |
| LOW⚡ | ui-next/src/utils/utils.ts | 241 | // Step 2: Loop through the sorted array and find the missing numbers | COMMENT |
| LOW | ui-next/src/utils/utils.ts | 254 | // Step 3: Return the next missing number | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1708 | // Step 1: Apply * mapping to all tasks, if present. | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1722 | // Step 2: Override additional mappings. | 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 | 490 | // Step 1: strip trailing __N (turn counter) | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/service/AgentEventListener.java | 493 | // Step 2: strip strategy-indexed prefixes | COMMENT |
| LOW | …r/ai/agentspan/runtime/service/AgentEventListener.java | 505 | // Step 3: strip leading N_ index prefix (e.g. "0_billing") | COMMENT |
| LOW | …ductor/ai/agentspan/runtime/compiler/ToolCompiler.java | 982 | // Step 1: HTTP task to fetch the spec | COMMENT |
| LOW | …ductor/ai/agentspan/runtime/compiler/ToolCompiler.java | 1004 | // Step 2: INLINE task to parse the OpenAPI/Swagger/Postman spec | 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 | 41 | ### Step 1: Creating the workflow by code | COMMENT |
| LOW | docs/documentation/clientsdks/go-sdk.md | 133 | ### Step 2: Creating the worker | COMMENT |
| LOW | docs/documentation/clientsdks/go-sdk.md | 152 | ### Step 3: Running the application | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 15 | ## Step 1: Start an MCP server | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 30 | ## Step 2: Configure your LLM provider | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 43 | ## Step 3: Create the agent workflow | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 131 | ## Step 4: Register and run | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 157 | ## Step 5: Add human approval | COMMENT |
| LOW | docs/devguide/ai/first-ai-agent.md | 192 | ## Step 6: Make it autonomous | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 69 | ### Step 1: Create the workflow | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 172 | ### Step 2: Create the compensation workflow | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 178 | ### Step 3: Write a custom worker | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 200 | ### Step 4: Run the workflow | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 211 | ### Step 5: Approve the review | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 220 | ### Step 6: Monitor and debug | COMMENT |
| LOW | docs/devguide/how-tos/conductor-skills.md | 236 | ### 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 | 113 | ### Step 1: Register a Workflow | COMMENT |
| LOW⚡ | ai/examples/README.md | 122 | ### Step 2: Execute the Workflow | COMMENT |
| LOW⚡ | ai/examples/README.md | 131 | ### 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 |
| 31 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 | 238 | // Step 1: Sort the array | COMMENT |
| LOW⚡ | ui-next/src/utils/utils.ts | 241 | // Step 2: Loop through the sorted array and find the missing numbers | COMMENT |
| LOW | ui-next/src/utils/utils.ts | 254 | // Step 3: Return the next missing number | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1708 | // Step 1: Apply * mapping to all tasks, if present. | COMMENT |
| LOW | …flix/conductor/core/execution/WorkflowExecutorOps.java | 1722 | // 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⚡ | …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 | 490 | // Step 1: strip trailing __N (turn counter) | COMMENT |
| LOW⚡ | …r/ai/agentspan/runtime/service/AgentEventListener.java | 493 | // Step 2: strip strategy-indexed prefixes | COMMENT |
| LOW | …r/ai/agentspan/runtime/service/AgentEventListener.java | 505 | // Step 3: strip leading N_ index prefix (e.g. "0_billing") | COMMENT |
| LOW | …ductor/ai/agentspan/runtime/compiler/ToolCompiler.java | 982 | // Step 1: HTTP task to fetch the spec | COMMENT |
| LOW | …ductor/ai/agentspan/runtime/compiler/ToolCompiler.java | 1004 | // Step 2: INLINE task to parse the OpenAPI/Swagger/Postman spec | 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 |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| 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 | 441 | // | COMMENT |
| LOW | ui-next/e2e/snapshots.spec.ts | 81 | "event-handler-defs.png", | COMMENT |
| LOW | …orPanel/TaskFormTab/forms/SimpleTaskForm/SampleCode.ts | 101 | COMMENT | |
| LOW | ui-next/src/pages/definition/state/action.ts | 641 | ActorRef<WorkflowMetadataEvents> | 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 | …/agentspan/runtime/service/PlanAndCompileTaskTest.java | 1001 | } | COMMENT |
| LOW | …/agentspan/runtime/service/PlanAndCompileTaskTest.java | 1901 | assertThat((String) all_) | COMMENT |
| LOW | …r/ai/agentspan/runtime/compiler/AgentCompilerTest.java | 1481 | COMMENT | |
| LOW | …uctor/ai/agentspan/runtime/util/JavaScriptBuilder.java | 581 | // at dynamic-task emission. The '$' + '{...' split is load-bearing: the | COMMENT |
| LOW | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 721 | parseTask.put("taskReferenceName", parseRef); | COMMENT |
| LOW | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 961 | // no `.result` wrapping (see _dispatch.py:493 in the Python | COMMENT |
| LOW | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 1041 | List<GuardrailConfig> guardrails, | COMMENT |
| LOW | …r/ai/agentspan/runtime/service/PlanAndCompileTask.java | 1141 | COMMENT | |
| LOW | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2241 | COMMENT | |
| LOW | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2321 | // Serialise the full ToolConfig list to Maps so PAC can deserialise | COMMENT |
| LOW | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2401 | "expression", JavaScriptBuilder.nullCoalesceScript())); | COMMENT |
| LOW | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2501 | // per-tool tasks receive via injectAmbient. A reader tool that | COMMENT |
| LOW | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2521 | tasks.add(planReaderTask); | COMMENT |
| LOW | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2601 | Map.of("switchCaseValue", "${" + hasJsonRef + ".output.result}")); | COMMENT |
| LOW | …/ai/agentspan/runtime/compiler/MultiAgentCompiler.java | 2781 | Map<String, Object> execInputs = new LinkedHashMap<>(); | COMMENT |
| LOW | …r/ai/agentspan/runtime/compiler/GuardrailCompiler.java | 361 | COMMENT | |
| LOW | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 1401 | messages.add(Map.of("role", "system", "message", instrText)); | COMMENT |
| LOW | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 1481 | // ``thinkingConfig: {enabled, budgetTokens}`` map here would be silently dropped and | COMMENT |
| LOW | …uctor/ai/agentspan/runtime/compiler/AgentCompiler.java | 1501 | // | 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 |
| 14 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | ai/README.md | 697 | export OPENAI_API_KEY=sk-your-api-key | CODE |
| HIGH⚡ | ai/README.md | 698 | export ANTHROPIC_API_KEY=sk-ant-your-api-key | CODE |
| HIGH⚡ | ai/README.md | 705 | $env:OPENAI_API_KEY = "sk-your-api-key" | CODE |
| HIGH⚡ | ai/README.md | 706 | $env:ANTHROPIC_API_KEY = "sk-ant-your-api-key" | CODE |
| HIGH | ai/README.md | 721 | -e OPENAI_API_KEY=sk-your-api-key \ | CODE |
| HIGH | ai/README.md | 722 | -e ANTHROPIC_API_KEY=sk-ant-your-api-key \ | CODE |
| HIGH | ai/README.md | 747 | OPENAI_API_KEY=sk-your-api-key | CODE |
| HIGH | ai/README.md | 748 | ANTHROPIC_API_KEY=sk-ant-your-api-key | CODE |
| HIGH | ai/README.md | 765 | -e GEMINI_API_KEY=your-api-key \ | CODE |
| HIGH | …ross/conductor/ai/vectordb/VectorDBInstanceConfig.java | 45 | * 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/src/utils/helpers.ts | 238 | 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/query.ts | 507 | export function useWorkflowNamesAndVersions(): Map<string, number[]> { | CODE |
| LOW | ui-next/src/utils/query.ts | 516 | export function useWorkflowDefsByVersions({ | CODE |
| LOW | …xt/src/utils/hooks/useWorkflowNamesAndVersionsQuery.ts | 9 | export function useWorkflowNamesAndVersionsQuery(): [ | 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 | 496 | function buildWorkflowDefByVersions( | CODE |
| LOW | ui-next/src/pages/scheduler/hooks/useCronExpression.ts | 23 | function calculateLastDayOffsetMatches( | 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 | 288 | function transformChainWorkflowToAgentRun( | CODE |
| LOW | …/pages/execution/AgentExecution/agentExecutionUtils.ts | 492 | export function transformWorkflowExecutionToAgentRun( | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/pages/execution/AgentExecution/agentExecutionUtils.ts | 524 | // Build set of guardrail function names from agentDef for robust detection | COMMENT |
| MEDIUM | …span-server/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 | 73 | * /dg #6: compile a plan against a PLAN_EXECUTE harness config and return the resulting | COMMENT |
| MEDIUM | …nductor/ai/agentspan/runtime/service/AgentService.java | 118 | * /dg #6: compile a plan against a PLAN_EXECUTE harness config and return the resulting | COMMENT |
| MEDIUM | …java/io/conductor/e2e/workflow/WorkflowRerunTests.java | 5622 | // to be robust to convention drift across versions. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| 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 | 197 | "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 | 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 | conductor_server.sh | 5 | # Usage: | COMMENT |
| 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 |