Battle-tested at Netflix Scale

Build AI Agents and Workflows
Scale With Confidence

Orkes is the battle-tested orchestration platform rooted in open-source with built-in reliability, observability, and control.

Start for free

Process Payment Worker

public class PaymentWorkers {
    private final PaymentRepository paymentRepository;

    public PaymentWorkers(PaymentRepository paymentRepository) {
        this.paymentRepository = paymentRepository;
    }

    @WorkerTask("ProcessPayment")
    public PaymentResult processPayment(PaymentDetails paymentDetails) {
        return this.paymentRepository.processPayment(paymentDetails);
    }

    @WorkerTask("RefundPayment")
    public RefundResult refundPayment(String transactionId) {
        return this.paymentRepository.refundPayment(transactionId);
    }

    @WorkerTask("GetPaymentStatus")
    public PaymentStatus getPaymentStatus(String transactionId) {
        return this.paymentRepository.getPaymentStatus(transactionId);
    }
}

{
  "createTime": 1759861689504,
  "updateTime": 1759861689504,
  "name": "ProcessTransaction",
  "description": "Processes a financial transaction",
  "version": 1,
  "tasks": [
    {
      "name": "GetAccountInfo",
      "taskReferenceName": "GetAccountInfo",
      "inputParameters": {
        "llmProvider": "Gemini",
        "model": "gemini-2.0-flash",
        "promptName": "ExtractAccountInfo",
        "promptVariables": {
          "accountSummary": "${workflow.input.accountSummary}"
        }
      },
      "type": "LLM_TEXT_COMPLETE",
      "decisionCases": {},
      "defaultCase": [],
      "forkTasks": [],
      "startDelay": 0,
      "joinOn": [],
      "optional": false,
      "defaultExclusiveJoinTask": [],
      "asyncComplete": false,
      "loopOver": [],
      "onStateChange": {},
      "permissive": false
    },
    {
      "name": "switch",
      "taskReferenceName": "switch_ref",
      "inputParameters": {
        "switchCaseValue": ""
      },
      "type": "SWITCH",
      "decisionCases": {
        "switch_case": [
          {
            "name": "FraudDetection",
            "taskReferenceName": "FraudDetection",
            "inputParameters": {
              "transaction": "${workflow.input.transactionInfo}",
              "account": "${GetAccountInfo.output.response}"
            },
            "type": "SIMPLE",
            "decisionCases": {},
            "defaultCase": [],
            "forkTasks": [],
            "startDelay": 0,
            "joinOn": [],
            "optional": false,
            "defaultExclusiveJoinTask": [],
            "asyncComplete": false,
            "loopOver": [],
            "onStateChange": {},
            "permissive": false
          }
        ]
      },
      "defaultCase": [
        {
          "name": "ProcessPayment",
          "taskReferenceName": "ProcessPayment",
          "inputParameters": {
            "transaction": "${workflow.input.transactionInfo}",
            "account": "${GetAccountInfo.output.response}"
          },
          "type": "SIMPLE",
          "decisionCases": {},
          "defaultCase": [],
          "forkTasks": [],
          "startDelay": 0,
          "joinOn": [],
          "optional": false,
          "defaultExclusiveJoinTask": [],
          "asyncComplete": false,
          "loopOver": [],
          "onStateChange": {},
          "permissive": false
        }
      ],
      "forkTasks": [],
      "startDelay": 0,
      "joinOn": [],
      "optional": false,
      "defaultExclusiveJoinTask": [],
      "asyncComplete": false,
      "loopOver": [],
      "evaluatorType": "value-param",
      "expression": "switchCaseValue",
      "onStateChange": {},
      "permissive": false
    },
    {
      "name": "SendNotification",
      "taskReferenceName": "SendNotification",
      "inputParameters": {
        "account": "${GetAccountInfo.output.response}"
      },
      "type": "SIMPLE",
      "decisionCases": {},
      "defaultCase": [],
      "forkTasks": [],
      "startDelay": 0,
      "joinOn": [],
      "optional": false,
      "defaultExclusiveJoinTask": [],
      "asyncComplete": false,
      "loopOver": [],
      "onStateChange": {},
      "permissive": false
    }
  ],
  "inputParameters": [
    "accountSummary",
    "transactionInfo"
  ],
  "outputParameters": {},
  "failureWorkflow": "",
  "schemaVersion": 2,
  "restartable": true,
  "workflowStatusListenerEnabled": false,
  "ownerEmail": "test@example.com",
  "timeoutPolicy": "ALERT_ONLY",
  "timeoutSeconds": 0,
  "variables": {},
  "inputTemplate": {},
  "enforceSchema": true,
  "metadata": {},
  "maskedFields": []
}

Used by 1,000's of Organizations Globally

The Agentic Workflow Orchestration Platform

Bring AI agents, services, and humans together in one workflow

AI Agents

Agentic decision making with workflows that reason, adapt and act

Humans

Keep humans in the loop for approvals, oversight, and exception handling

Services

Orchestrate microservices, APIs and tools via MCP natively

Beyond the POC: Making Agents Reliable at Scale

Orchestration is the missing layer that moves agents from demos to production.

MCP Gateway

Turn internal APIs into safe, consistent tools that agents and LLMs can use right away.

Agentic Workflows

Blend structured process stages with LLM driven decisions to handle real world complexity.

Prompt to Workflow

Turn natural language into a strong starter workflow you can review, edit, and ship fast.

Learn more

Build Workflows

Design Processes

Model workflows visually with drag-and-drop, code via SDKs, or define them in config with JSON

Polyglot Business Logic

Build microservices in any any language using our open source SDKs and easily orchestrate them in your workflows

Build event-driven systems

Easily consume external events to guide workflow execution and use built-in tasks to publish events to your message queues

1public class UserWorkers {
2    private final UserRepository userRepository;
3
4    public UserWorkers(UserRepository userRepository) {
5        this.userRepository = userRepository;
6    }
7
8    @WorkerTask("GetUserInformation")
9    public UserProfile getUserInformation(String userID) {
10        return this.userRepository.getUserById(userID);
11    }
12
13    @WorkerTask("UpdateUserInformation")
14    public UpdateResult updateUserInformation(UserProfile newInfo) {
15        return this.userRepository.updateUserInformation(newInfo);
16    }
17
18    @WorkerTask("DeleteUser")
19    public DeleteResult deleteUser(String userID) {
20        return this.userRepository.deleteUser(userID);
21    }
22}

Orchestrate APIs & Microservices

Execute durable asynchronous workflows and synchronous low-latency workflows in the same platform

Bring Any API

Call any HTTP or gRPC service from your workflows easily with built-in system tasks

Reliable at scale

Fault-tolerant and highly durable execution at high loads with minimal latency

Expose as APIs

Fully API driven platform with open source SDKs in your favorite language, and integrations with the tools you already use.

Observe and Govern

Complete visibility and control over your entire orchestration platform

Real-time Monitoring

Track every execution in real-time

Analytics

Detailed performance metrics

Access Control

Fine-grained RBAC policies

Audit Logs

Complete audit trail

Developer First by Design
Powered by Open Source

Simple APIs, SDKs in your favorite language, and integrations with the tools you already use.

import io.orkes.conductor.client.ApiClient;
import io.orkes.conductor.client.ApiException;
import io.orkes.conductor.client.api.WorkflowApi;
import io.orkes.conductor.client.model.StartWorkflowRequest;
import io.orkes.conductor.client.model.StartWorkflowResponse;

public class WorkflowExecutor {
    public static void main(String[] args) {
        ApiClient client = new ApiClient();
        client.setBasePath("https://api.orkes.io");
        client.setApiKey("YOUR_API_KEY");

        WorkflowApi api = new WorkflowApi(client);

        StartWorkflowRequest request = new StartWorkflowRequest();
        request.setName("ai-agent-workflow");
        request.setVersion(1);
        request.setInput(null);

        try {
            StartWorkflowResponse response = api.startWorkflow(request);
            System.out.println("Workflow started successfully with ID: " + response.getWorkflowId());
        } catch (ApiException e) {
            System.err.println("Error starting workflow: " + e.getMessage());
        }
    }
}

CLI & SDKs

Native SDKs for Python, Java, JavaScript, C#, Go, and more.

Version Control

Git-like versioning for your workflows with rollback support.

Real-time Monitoring

Debug workflows with step-by-step execution visualization.

State Management

Automatic state persistence and recovery on failures.

Enterprise Ready, Battle Tested

Trusted by Fortune 500 companies to handle their most critical workflows.

Up to 99.99%

Availability SLA

1B+

Workflows Executed Daily

Flexible deployments

AWS, Azure, GCP or on-prem

Mission Critical Support

Enterprise Plans

Gartner® Hype Cycle™ for
Enterprise Process Automation

Get the report

Ready to Build Something Amazing?

Join thousands of developers building the future with Orkes.

Start for free

Build AI Agents and Workflows
Scale With Confidence

Orkes is the battle-tested orchestration platform rooted in open-source with built-in reliability, observability, and control.

Process Payment Worker

public class PaymentWorkers {
    private final PaymentRepository paymentRepository;

    public PaymentWorkers(PaymentRepository paymentRepository) {
        this.paymentRepository = paymentRepository;
    }

    @WorkerTask("ProcessPayment")
    public PaymentResult processPayment(PaymentDetails paymentDetails) {
        return this.paymentRepository.processPayment(paymentDetails);
    }

    @WorkerTask("RefundPayment")
    public RefundResult refundPayment(String transactionId) {
        return this.paymentRepository.refundPayment(transactionId);
    }

    @WorkerTask("GetPaymentStatus")
    public PaymentStatus getPaymentStatus(String transactionId) {
        return this.paymentRepository.getPaymentStatus(transactionId);
    }
}

{
  "createTime": 1759861689504,
  "updateTime": 1759861689504,
  "name": "ProcessTransaction",
  "description": "Processes a financial transaction",
  "version": 1,
  "tasks": [
    {
      "name": "GetAccountInfo",
      "taskReferenceName": "GetAccountInfo",
      "inputParameters": {
        "llmProvider": "Gemini",
        "model": "gemini-2.0-flash",
        "promptName": "ExtractAccountInfo",
        "promptVariables": {
          "accountSummary": "${workflow.input.accountSummary}"
        }
      },
      "type": "LLM_TEXT_COMPLETE",
      "decisionCases": {},
      "defaultCase": [],
      "forkTasks": [],
      "startDelay": 0,
      "joinOn": [],
      "optional": false,
      "defaultExclusiveJoinTask": [],
      "asyncComplete": false,
      "loopOver": [],
      "onStateChange": {},
      "permissive": false
    },
    {
      "name": "switch",
      "taskReferenceName": "switch_ref",
      "inputParameters": {
        "switchCaseValue": ""
      },
      "type": "SWITCH",
      "decisionCases": {
        "switch_case": [
          {
            "name": "FraudDetection",
            "taskReferenceName": "FraudDetection",
            "inputParameters": {
              "transaction": "${workflow.input.transactionInfo}",
              "account": "${GetAccountInfo.output.response}"
            },
            "type": "SIMPLE",
            "decisionCases": {},
            "defaultCase": [],
            "forkTasks": [],
            "startDelay": 0,
            "joinOn": [],
            "optional": false,
            "defaultExclusiveJoinTask": [],
            "asyncComplete": false,
            "loopOver": [],
            "onStateChange": {},
            "permissive": false
          }
        ]
      },
      "defaultCase": [
        {
          "name": "ProcessPayment",
          "taskReferenceName": "ProcessPayment",
          "inputParameters": {
            "transaction": "${workflow.input.transactionInfo}",
            "account": "${GetAccountInfo.output.response}"
          },
          "type": "SIMPLE",
          "decisionCases": {},
          "defaultCase": [],
          "forkTasks": [],
          "startDelay": 0,
          "joinOn": [],
          "optional": false,
          "defaultExclusiveJoinTask": [],
          "asyncComplete": false,
          "loopOver": [],
          "onStateChange": {},
          "permissive": false
        }
      ],
      "forkTasks": [],
      "startDelay": 0,
      "joinOn": [],
      "optional": false,
      "defaultExclusiveJoinTask": [],
      "asyncComplete": false,
      "loopOver": [],
      "evaluatorType": "value-param",
      "expression": "switchCaseValue",
      "onStateChange": {},
      "permissive": false
    },
    {
      "name": "SendNotification",
      "taskReferenceName": "SendNotification",
      "inputParameters": {
        "account": "${GetAccountInfo.output.response}"
      },
      "type": "SIMPLE",
      "decisionCases": {},
      "defaultCase": [],
      "forkTasks": [],
      "startDelay": 0,
      "joinOn": [],
      "optional": false,
      "defaultExclusiveJoinTask": [],
      "asyncComplete": false,
      "loopOver": [],
      "onStateChange": {},
      "permissive": false
    }
  ],
  "inputParameters": [
    "accountSummary",
    "transactionInfo"
  ],
  "outputParameters": {},
  "failureWorkflow": "",
  "schemaVersion": 2,
  "restartable": true,
  "workflowStatusListenerEnabled": false,
  "ownerEmail": "test@example.com",
  "timeoutPolicy": "ALERT_ONLY",
  "timeoutSeconds": 0,
  "variables": {},
  "inputTemplate": {},
  "enforceSchema": true,
  "metadata": {},
  "maskedFields": []
}

Used by 1,000's of Organizations Globally

1public class UserWorkers { 2 private final UserRepository userRepository; 3 4 public UserWorkers(UserRepository userRepository) { 5 this.userRepository = userRepository; 6 } 7 8 @WorkerTask("GetUserInformation") 9 public UserProfile getUserInformation(String userID) { 10 return this.userRepository.getUserById(userID); 11 } 12 13 @WorkerTask("UpdateUserInformation") 14 public UpdateResult updateUserInformation(UserProfile newInfo) { 15 return this.userRepository.updateUserInformation(newInfo); 16 } 17 18 @WorkerTask("DeleteUser") 19 public DeleteResult deleteUser(String userID) { 20 return this.userRepository.deleteUser(userID); 21 } 22}

import io.orkes.conductor.client.ApiClient; import io.orkes.conductor.client.ApiException; import io.orkes.conductor.client.api.WorkflowApi; import io.orkes.conductor.client.model.StartWorkflowRequest; import io.orkes.conductor.client.model.StartWorkflowResponse; public class WorkflowExecutor { public static void main(String[] args) { ApiClient client = new ApiClient(); client.setBasePath("https://api.orkes.io"); client.setApiKey("YOUR_API_KEY"); WorkflowApi api = new WorkflowApi(client); StartWorkflowRequest request = new StartWorkflowRequest(); request.setName("ai-agent-workflow"); request.setVersion(1); request.setInput(null); try { StartWorkflowResponse response = api.startWorkflow(request); System.out.println("Workflow started successfully with ID: " + response.getWorkflowId()); } catch (ApiException e) { System.err.println("Error starting workflow: " + e.getMessage()); } } }

Build AI Agents and Workflows Scale With Confidence

The Agentic Workflow Orchestration Platform

AI Agents

Humans

Services

Beyond the POC: Making Agents Reliable at Scale

MCP Gateway

Agentic Workflows

Prompt to Workflow

Build Workflows

Design Processes

Polyglot Business Logic

Build event-driven systems

Orchestrate APIs & Microservices

Bring Any API

Reliable at scale

Expose as APIs

Observe and Govern

Real-time Monitoring

Analytics

Access Control

Audit Logs

Developer First by Design Powered by Open Source

Enterprise Ready, Battle Tested

Up to 99.99%

1B+

Flexible deployments

Mission Critical Support

Gartner® Hype Cycle™ forEnterprise Process Automation

Ready to Build Something Amazing?

Company

Product

Community

Use Cases

Compare

Build AI Agents and Workflows Scale With Confidence

The Agentic Workflow Orchestration Platform

AI Agents

Humans

Services

Beyond the POC: Making Agents Reliable at Scale

MCP Gateway

Agentic Workflows

Prompt to Workflow

Build Workflows

Design Processes

Polyglot Business Logic

Build event-driven systems

Orchestrate APIs & Microservices

Bring Any API

Reliable at scale

Expose as APIs

Observe and Govern

Real-time Monitoring

Analytics

Access Control

Audit Logs

Developer First by Design Powered by Open Source

Enterprise Ready, Battle Tested

Up to 99.99%

1B+

Flexible deployments

Mission Critical Support

Gartner® Hype Cycle™ forEnterprise Process Automation

Ready to Build Something Amazing?

Build AI Agents and Workflows
Scale With Confidence

Developer First by Design
Powered by Open Source

Gartner® Hype Cycle™ for
Enterprise Process Automation

Build AI Agents and Workflows
Scale With Confidence

Developer First by Design
Powered by Open Source

Gartner® Hype Cycle™ for
Enterprise Process Automation