Skip to content

Advanced Process Example

Enterprise Orchestration

Part of 400+ modules with 12 workflow types including DAG, parallel, and consensus-based orchestration. See Processes Documentation.

Python
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
import logging

logger = logging.getLogger(__name__)

from agenticaiframework.processes import Process

# Example: Advanced Process usage with Tasks
# -------------------------------------------
# This example demonstrates how to:
# 1. Create a Process
# 2. Add multiple Task callables to it
# 3. Execute them in sequence
#
# Expected Output:
# - Logs showing execution of each task in order

if __name__ == "__main__":
    # Create a process
    process = Process(name="AdvancedProcess", strategy="sequential")

    # Define some tasks
    def task_one():
        logger.info("Task One executed.")

    def task_two():
        logger.info("Task Two executed.")

    def task_three():
        logger.info("Task Three executed.")

    # Add tasks to the process
    process.add_task(task_one)
    process.add_task(task_two)
    process.add_task(task_three)

    # Execute the process
    process.execute()