Home / conductor-oss / conductor
Repository Analysis

conductor-oss/conductor

Conductor is an event driven agentic workflow engine providing durable and highly resilient execution engine for applications and AI Agents

1.4 Likely human-written View on GitHub
1.4
Adjusted Score
1.4
Raw Score
100%
Time Factor
2026-05-29
Last Push
31,860
Stars
Java
Language
483,735
Lines of Code
3018
Files
194
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 27HIGH 10MEDIUM 46LOW 111

Pattern Findings

194 matches across 10 categories. Click a row to expand file-level details.

Hallucination Indicators27 hits · 300 pts
SeverityFileLineSnippet
CRITICAL…uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java462 new org.apache.kafka.common.errors.UnknownTopicOrPartitionException(
CRITICAL…netflix/conductor/redis/dao/RedisExecutionDAOTest.java380 new com.netflix.conductor.common.metadata.workflow.WorkflowTask();
CRITICAL…netflix/conductor/redis/dao/RedisExecutionDAOTest.java417 new com.netflix.conductor.common.metadata.workflow.WorkflowTask();
CRITICAL…netflix/conductor/benchmark/ScriptEngineBenchmark.java254 Object copy = com.netflix.conductor.core.events.ScriptEvaluator.deepCopy(input);
CRITICAL…netflix/conductor/benchmark/ScriptEngineBenchmark.java255 return com.netflix.conductor.core.events.ScriptEvaluator.eval(script, copy);
CRITICAL…netflix/conductor/benchmark/ScriptEngineBenchmark.java294 Object inputCopy = com.netflix.conductor.core.events.ScriptEvaluator.deepCopy(input);
CRITICAL…netflix/conductor/benchmark/ScriptEngineBenchmark.java356 v8 = com.caoccao.javet.interop.V8Host.getV8Instance().createV8Runtime();
CRITICAL…netflix/conductor/benchmark/ScriptEngineBenchmark.java360 v8.setConverter(new com.caoccao.javet.interop.converters.JavetObjectConverter());
CRITICAL…netflix/conductor/benchmark/ScriptEngineBenchmark.java368 Object inputCopy = com.netflix.conductor.core.events.ScriptEvaluator.deepCopy(input);
CRITICAL…x/conductor/sqs/eventqueue/SQSObservableQueueTest.java78 software.amazon.awssdk.services.sqs.model.Message.builder()
CRITICAL…conductor/es8/config/ElasticSearchV8Configuration.java130 return org.apache.http.ssl.SSLContexts.custom().loadTrustMaterial(trustStore, null).build();
CRITICAL…nductoross/conductor/ai/LLMHelperChatCompleteTest.java583 org.junit.jupiter.api.Assertions.assertThrows(
CRITICAL…s/conductor/ai/integration/AIModelIntegrationTest.java802 com.google.auth.oauth2.GoogleCredentials.fromStream(
CRITICAL…ss/conductor/ai/providers/gemini/GeminiVertexTest.java147 org.junit.jupiter.api.Assumptions.assumeTrue(
CRITICAL…main/java/org/conductoross/conductor/ai/LLMHelper.java431 org.conductoross.conductor.ai.models.Media.builder()
CRITICAL…main/java/org/conductoross/conductor/ai/LLMHelper.java508 org.conductoross.conductor.ai.models.Media.builder()
CRITICAL…main/java/org/conductoross/conductor/ai/LLMHelper.java520 org.conductoross.conductor.ai.models.Media.builder()
CRITICAL…main/java/org/conductoross/conductor/ai/LLMHelper.java529 org.conductoross.conductor.ai.models.Media.builder()
CRITICAL…oross/conductor/ai/providers/gemini/api/GeminiApi.java75 new com.netflix.conductor.common.config.ObjectMapperProvider().getObjectMapper();
CRITICAL…ss/conductor/ai/providers/stabilityai/StabilityAI.java145 return org.springframework.ai.image.ImageOptionsBuilder.builder()
CRITICAL…ctor/ai/providers/openai/OpenAIResponsesChatModel.java267 new org.springframework.ai.chat.metadata.DefaultUsage(
CRITICAL…/test/java/io/conductor/e2e/workflow/JavaSDKTests.java95 @com.netflix.conductor.sdk.workflow.task.InputParam("name") String name) {
CRITICAL…t/java/io/conductor/e2e/workflow/ClearContextTest.java53 new com.netflix.conductor.common.metadata.workflow.WorkflowTask();
CRITICAL…t/java/io/conductor/e2e/workflow/ClearContextTest.java81 new com.netflix.conductor.common.metadata.workflow.StartWorkflowRequest();
CRITICAL…t/java/io/conductor/e2e/workflow/ClearContextTest.java89 org.junit.jupiter.api.Assertions.assertTrue(
CRITICAL…x/conductor/rest/controllers/WorkflowResourceTest.java592 List.of(new com.netflix.conductor.common.metadata.workflow.WorkflowTask()));
CRITICAL…x/conductor/rest/controllers/WorkflowResourceTest.java866 List.of(new com.netflix.conductor.common.metadata.workflow.WorkflowTask()));
Decorative Section Separators46 hits · 166 pts
SeverityFileLineSnippet
MEDIUMui/e2e/pages.spec.ts15 // ── Executions ──────────────────────────────────────────────────────────────
MEDIUMui/e2e/pages.spec.ts43 // ── Definitions ─────────────────────────────────────────────────────────────
MEDIUMui/e2e/pages.spec.ts101 // ── Scheduler Executions ─────────────────────────────────────────────────────
MEDIUMui/e2e/pages.spec.ts118 // ── Task Queue ───────────────────────────────────────────────────────────────
MEDIUMui/e2e/pages.spec.ts156 // ── Workbench ────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/api-client.ts16// ── Types ─────────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/api-client.ts60// ── Helpers ───────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/api-client.ts82// ── Workflow definitions ───────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/api-client.ts109// ── Workflow executions ────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/api-client.ts160// ── Task definitions ──────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/task-definitions.spec.ts23// ── Fixtures ──────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/task-definitions.spec.ts38// ── Tests ─────────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/executions.spec.ts50// ── Helpers ────────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/executions.spec.ts66// ── Tests ─────────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/workflows.spec.ts40// ── Fixtures ──────────────────────────────────────────────────────────────────
MEDIUMui-next/e2e/integration/workflows.spec.ts55// ── Tests ─────────────────────────────────────────────────────────────────────
MEDIUM…conductor/core/storage/FileStorageServiceImplTest.java140 // ── Upload enforcement ────────────────────────────────────────────────────
MEDIUM…conductor/core/storage/FileStorageServiceImplTest.java151 // ── Download enforcement ──────────────────────────────────────────────────
MEDIUM…tor/core/execution/TestWorkflowExecutorDecideLoop.java182 // ── helpers ──────────────────────────────────────────────────────────────
MEDIUMai/src/test/resources/ai-test-env.sh11# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh13# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh18# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh20# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh25# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh27# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh36# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh38# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh43# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh45# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh52# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh54# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh58# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh60# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh64# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh66# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh70# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh72# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh78# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh80# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh85# ============================================================================
MEDIUMai/src/test/resources/ai-test-env.sh87# ============================================================================
MEDIUM.github/dependabot.yml12 # -----------------------------------------------------------------------
MEDIUM.github/dependabot.yml15 # -----------------------------------------------------------------------
MEDIUM.github/dependabot.yml31 # -----------------------------------------------------------------------
MEDIUM.github/dependabot.yml33 # -----------------------------------------------------------------------
MEDIUM…a/io/conductor/e2e/filestorage/FileStorageE2ETest.java200 // ── workflowId scoping ────────────────────────────────────────────────────
Verbosity Indicators35 hits · 67 pts
SeverityFileLineSnippet
LOW…uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java377 // Step 1: Mock TopicDescription
LOW…uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java395 // Step 2: Mock Offsets
LOW…uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java411 // Step 3: Call the `size` method
LOW…uctor/kafkaeq/eventqueue/KafkaObservableQueueTest.java414 // Step 4: Verify the size is correctly calculated
LOWui-next/src/utils/utils.ts238 // Step 1: Sort the array
LOWui-next/src/utils/utils.ts241 // Step 2: Loop through the sorted array and find the missing numbers
LOWui-next/src/utils/utils.ts254 // Step 3: Return the next missing number
LOW…flix/conductor/core/execution/WorkflowExecutorOps.java1612 // Step 1: Apply * mapping to all tasks, if present.
LOW…flix/conductor/core/execution/WorkflowExecutorOps.java1626 // Step 2: Override additional mappings.
LOW…om/netflix/conductor/core/execution/tasks/DoWhile.java161 // if we are here, the iteration is complete, and we need to check if there is a next
LOW…toross/conductor/ai/video/VideoProviderMemoryTest.java43 // Step 1: Store using fromBytes (optimized way)
LOW…toross/conductor/ai/video/VideoProviderMemoryTest.java46 // Step 2: Access bytes
LOW…toross/conductor/ai/video/VideoProviderMemoryTest.java49 // Step 3: Store in Media
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java65 // Step 1: Parse markdown to AST
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java68 // Step 2: Create PDF document
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java70 // Step 3: Configure page size
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java73 // Step 4: Set PDF metadata
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java76 // Step 5: Create render context
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java89 // Step 6: Render AST to PDF
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java94 // Step 7: Close the last content stream
LOW…ductoross/conductor/ai/pdf/MarkdownToPdfConverter.java99 // Step 8: Save to bytes
LOW…t/java/io/conductor/e2e/workflow/ClearContextTest.java44 // Step 1: Register a test task definition
LOW…t/java/io/conductor/e2e/workflow/ClearContextTest.java50 // Step 2: Register a workflow definition using this task
LOW…t/java/io/conductor/e2e/workflow/ClearContextTest.java66 // Step 3: Start a thread that constantly calls updateTaskDef
LOW…t/java/io/conductor/e2e/workflow/ClearContextTest.java79 // Step 4: Start a workflow while the updater thread is running
LOW…t/java/io/conductor/e2e/workflow/ClearContextTest.java86 // Step 5: Fetch the workflow and assert ownerApp is empty
LOW…va/io/conductor/e2e/task/ConcurrentExecLimitTests.java244 // Step 1: poll first task - should get exactly one because concurrentExecLimit=1.
LOW…va/io/conductor/e2e/task/ConcurrentExecLimitTests.java252 // Step 2: poll again - should be empty because B fails exceedsInProgressLimit and gets
LOW…va/io/conductor/e2e/task/ConcurrentExecLimitTests.java262 // Step 3: complete A. This frees the slot and (post-fix) releases B's postpone.
LOW…va/io/conductor/e2e/task/ConcurrentExecLimitTests.java271 // Step 4: B should now be pollable quickly. Allow 5s; pre-fix the bug forces ~60s.
LOW…a/io/conductor/e2e/control/SubWorkflowInlineTests.java186 // Step 1: wf_builder SIMPLE task is SCHEDULED — wait then complete it with the
LOW…a/io/conductor/e2e/control/SubWorkflowInlineTests.java208 // Step 2: The SUB_WORKFLOW task must become IN_PROGRESS, meaning the expression was
LOW…a/io/conductor/e2e/control/SubWorkflowInlineTests.java227 // Step 3: Iteration 1 (product = 1×5 = 5, 5 > 5 = false) runs entirely via system
LOW…a/io/conductor/e2e/control/SubWorkflowInlineTests.java260 // Step 4: After high_task completes, the DO_WHILE condition evaluates to false
LOW…a/io/conductor/e2e/control/SubWorkflowInlineTests.java279 // Step 5: Parent workflow completes once the SUB_WORKFLOW task is done.
Magic Placeholder Names10 hits · 62 pts
SeverityFileLineSnippet
HIGHai/README.md665export OPENAI_API_KEY=sk-your-api-key
HIGHai/README.md666export ANTHROPIC_API_KEY=sk-ant-your-api-key
HIGHai/README.md673$env:OPENAI_API_KEY = "sk-your-api-key"
HIGHai/README.md674$env:ANTHROPIC_API_KEY = "sk-ant-your-api-key"
HIGHai/README.md689 -e OPENAI_API_KEY=sk-your-api-key \
HIGHai/README.md690 -e ANTHROPIC_API_KEY=sk-ant-your-api-key \
HIGHai/README.md715OPENAI_API_KEY=sk-your-api-key
HIGHai/README.md716ANTHROPIC_API_KEY=sk-ant-your-api-key
HIGHai/README.md733 -e GEMINI_API_KEY=your-api-key \
HIGH…ross/conductor/ai/vectordb/VectorDBInstanceConfig.java44 * apiKey: "your-api-key"
Over-Commented Block50 hits · 47 pts
SeverityFileLineSnippet
LOWconductor_server.sh1#!/bin/sh
LOWui/playwright/index.tsx1// Entry point for Playwright component testing.
LOWui/src/serviceWorker.js1// This optional code is used to register a service worker.
LOWui/src/setupTests.js1// jest-dom adds custom jest matchers for asserting on DOM nodes.
LOW…m/netflix/conductor/sqlite/dao/SqliteIndexDAOTest.java381 assertEquals("No results returned", 1, results.getResults().size());
LOWui-next/e2e/snapshots.spec.ts81 "event-handler-defs.png",
LOW…orPanel/TaskFormTab/forms/SimpleTaskForm/SampleCode.ts101
LOWui-next/src/pages/definition/state/action.ts641 ActorRef<WorkflowMetadataEvents>
LOW…va/com/netflix/conductor/redislock/lock/RedisLock.java101 // A Valid failure to acquire lock when another thread has acquired it returns false.
LOWdocker/docker-compose-ui-e2e.yaml1# Docker Compose stack for Playwright UI integration tests.
LOWdocker/server/bin/startup.sh1#!/bin/sh
LOW…ix/conductor/postgres/performance/PerformanceTest.java21// public static final int PRODUCER_BATCH = 10; // make sure MSGS % PRODUCER_BATCH == 0
LOW…ix/conductor/postgres/performance/PerformanceTest.java41// public void setUp() {
LOW…ix/conductor/postgres/performance/PerformanceTest.java61//
LOW…ix/conductor/postgres/performance/PerformanceTest.java81// Thread.sleep(200);
LOW…ix/conductor/postgres/performance/PerformanceTest.java101// }
LOW…ix/conductor/postgres/performance/PerformanceTest.java121// } catch (Exception e) {
LOW…ix/conductor/postgres/performance/PerformanceTest.java141//
LOW…ix/conductor/postgres/performance/PerformanceTest.java161// LOGGER.info("Unacked");
LOW…ix/conductor/postgres/performance/PerformanceTest.java181//
LOW…ix/conductor/postgres/performance/PerformanceTest.java201//
LOW…ix/conductor/postgres/performance/PerformanceTest.java221// while (true) {
LOW…ix/conductor/postgres/performance/PerformanceTest.java241//
LOW…ix/conductor/postgres/performance/PerformanceTest.java261// LOGGER.error("Something went wrong with worker during poll", e);
LOW…ix/conductor/postgres/performance/PerformanceTest.java281// throw new RuntimeException(e);
LOW…ix/conductor/postgres/performance/PerformanceTest.java301//
LOW…ix/conductor/postgres/performance/PerformanceTest.java321// LOGGER.info("Pushed ALL");
LOW…ix/conductor/postgres/performance/PerformanceTest.java341// E.getWorkflowsByCorrelationId("abcd", "2", true).size());
LOW…ix/conductor/postgres/performance/PerformanceTest.java361// Thread.sleep(COMPLETION_MONITOR_DELAY);
LOW…ix/conductor/postgres/performance/PerformanceTest.java381// }
LOW…ix/conductor/postgres/performance/PerformanceTest.java401// wf.setTasks(randomTasks);
LOW…ix/conductor/postgres/performance/PerformanceTest.java421// }).collect(Collectors.toList());
LOW…ix/conductor/postgres/performance/PerformanceTest.java441// try {
LOW…etflix/conductor/core/execution/tasks/DoWhileTest.java1401 assertFalse(
LOW…ross/conductor/model/WorkflowSignalReturnStrategy.java41 // made to notify with
LOWai/src/test/resources/ai-test-env.sh1#!/bin/bash
LOWai/src/test/resources/ai-test-env.sh21export ANTHROPIC_API_KEY="your-anthropic-api-key"
LOWai/src/test/resources/ai-test-env.sh41# export MISTRAL_BASE_URL="https://api.mistral.ai"
LOWai/src/test/resources/ai-test-env.sh61export COHERE_API_KEY="your-cohere-api-key"
LOW…toross/conductor/ai/vectordb/PostgresVectorDBTest.java321 // Verify query operator for cosine (<=>)
LOW…ai/mapper/AIModelTaskMapperPreviousResponseIdTest.java181 // sub-workflow tool calls, and media. Now only the same-refName
LOW…/conductor/ai/tasks/mapper/ChatCompleteTaskMapper.java181 // (b) the provider declares it doesn't accept assistant-message prefill
LOW…nductor/grpc/server/service/HealthServiceImplTest.java21 // @Rule
LOW…nductor/grpc/server/service/HealthServiceImplTest.java41 //
LOW…nductor/grpc/server/service/HealthServiceImplTest.java61 // addService(serverName, healthyService);
LOW…nductor/grpc/server/service/HealthServiceImplTest.java81 // when(hca.check()).thenReturn(hcsf);
LOW…/test/java/io/conductor/e2e/task/RetryPolicyTests.java721 // responseTimeout=3s, the sweeper would not re-evaluate until ~30s, missing
LOW…t/java/io/conductor/e2e/task/LLMChatCompleteTests.java561 // 1. chat (LLM_CHAT_COMPLETE) — previousResponseId=${workflow.variables.lastResponseId}
LOW…t/java/io/conductor/e2e/task/LLMChatCompleteTests.java641 // ====================================================================
LOW…lix/conductor/os/config/OpenSearchDeprecationTest.java61 assertTrue("Error should reference issue #678", message.contains("678"));
Hyper-Verbose Identifiers15 hits · 15 pts
SeverityFileLineSnippet
LOWui/src/data/workflow.js142export function useWorkflowNamesAndVersions() {
LOWui/src/data/scheduler.js71export function useSchedulerExecutionSearch(searchObj) {
LOWui-next/src/utils/helpers.ts238export function replacePathPlaceholdersToWorkflowInput(path: string): string {
LOWui-next/src/utils/workflow.ts327export function scanTasksForDependenciesInTasks(tasks: CommonTaskDef[]) {
LOWui-next/src/utils/workflow.ts378export function scanTasksForDependenciesInWorkflow(workflow: WorkflowDef) {
LOWui-next/src/utils/query.ts496export function useWorkflowNamesAndVersions(): Map<string, number[]> {
LOWui-next/src/utils/query.ts505export function useWorkflowDefsByVersions({
LOW…xt/src/utils/hooks/useWorkflowNamesAndVersionsQuery.ts9export function useWorkflowNamesAndVersionsQuery(): [
LOWui-next/src/components/features/auth/silentRefresh.ts14export function hasRefreshPermanentlyFailed(): boolean {
LOW…ts/features/flow/components/shapes/TaskCard/helpers.ts13export function dowhileHasAllIterationsInOutput(
LOWui-next/src/pages/scheduler/__tests__/hooks.test.ts496function buildWorkflowDefByVersions(
LOWui-next/src/pages/scheduler/hooks/useCronExpression.ts23function calculateLastDayOffsetMatches(
LOWui-next/src/pages/runWorkflow/runWorkflowUtils.ts139export function getTemplateFromInputParams(inputParamsArray: any) {
LOW…rPanel/TaskFormTab/forms/JOINTaskForm/JOINTaskForm.tsx87 async function setPossibleTaskReferencesAsync(
LOWui-next/src/pages/execution/helpers.ts42export function findTaskFromExecutionStatusMapById(
Fake / Example Data7 hits · 7 pts
SeverityFileLineSnippet
LOW…uctor/postgres/storage/PostgresPayloadStorageTest.java57 "Lorem Ipsum is simply dummy text of the printing and typesetting industry."
LOW…uctor/postgres/storage/PostgresPayloadStorageTest.java58 + " Lorem Ipsum has been the industry's standard dummy text ever since the 1500s.";
LOWdocs/documentation/configuration/taskdef.md197 "ownerEmail": "foo@bar.com",
LOW…on/configuration/workflowdef/systemtasks/human-task.md157 "approvedBy": "user@example.com",
LOWdocs/wmq/workflow-message-queue-architecture.md74 "approvedBy": "user@example.com"
LOW…or/test/integration/http/SchedulerIntegrationTest.java455 taskDef.put("ownerEmail", "test@test.com");
LOW…or/test/integration/http/SchedulerIntegrationTest.java463 wfDef.put("ownerEmail", "test@test.com");
Excessive Try-Catch Wrapping2 hits · 2 pts
SeverityFileLineSnippet
LOWscripts/fetch-sdk-docs.py50 except Exception:
LOWscripts/fetch-sdk-docs.py62 except Exception as e:
Example Usage Blocks1 hit · 2 pts
SeverityFileLineSnippet
LOWconductor_server.sh5# Usage:
Redundant / Tautological Comments1 hit · 1 pts
SeverityFileLineSnippet
LOWai/src/test/resources/ai-test-env.sh33# Set path to your service account JSON key file