Strands Workflow

Workflow

실행 순서를 보장하고 상태를 디스크에 남기는 프로덕션 지향 패턴

Workflow 구조도

고정 순서의 파이프라인 — 각 태스크 결과가 저장되어 실패 지점을 정확히 파악

1. 1
   수집

   태스크 1 — 결과를 상태 저장소에 기록

2. 2
   분석

   태스크 2 — 이전 태스크 결과를 입력으로 사용

3. 3
   작성

   태스크 3 — 실패하면 이 지점이 상태에 기록

4. 4
   발행

   태스크 4 — 완료 상태 기록으로 종료

Workflow 파이프라인 구현

strands-agents-tools의 workflow 도구로 의존성 기반 태스크 파이프라인 실행

핵심 포인트

workflow

strands-agents-tools가 제공하는 태스크 파이프라인 도구

tools=[workflow]

오케스트레이터에 장착 — 자연어 요청을 도구 호출로 수행

create / start / list / status / delete

workflow 도구가 지원하는 5가지 액션

workflow_id

status 액션으로 파이프라인별 진행 상태 확인

코드

from strands import Agent
from strands_tools import workflow

orchestrator = Agent(
    system_prompt="""You manage data pipelines.
    Use the workflow tool to create and run task pipelines.
    Define tasks with dependencies for execution order.""",
    tools=[workflow],
)

# 워크플로우 생성·실행 — 에이전트가 도구 호출로 수행
result = orchestrator("""
다음 데이터 파이프라인을 실행해줘:
1. ingest → 2. validate → 3. transform → 4. load
각 단계는 이전 단계에 의존합니다.
""")
# 태스크 상태는 디스크에 저장 — status로 workflow_id별 진행 확인

태스크 상태 저장과 추적

태스크 상태를 디스크에 기록해 장애 발생 지점을 파악하는 구조

1. 1
   태스크 실행

   의존성이 해소된 태스크부터 순차 실행

2. 2
   상태 저장

   태스크 완료 시마다 상태를 로컬 디스크에 기록

3. 3
   장애 감지

   타임아웃·예외·외부 실패 시 실행 중단

4. 4
   상태 조회

   status 액션으로 workflow_id별 완료·실패 태스크 확인 후 대응

컨텍스트는 어떻게 넘어가는가 — 패턴별 상태 전달

멀티에이전트 설계의 핵심 질문 — 각 패턴이 컨텍스트와 상태를 넘기는 방식

언제 멈추는가 — 패턴별 종료와 폭주 방지

상한 없는 자율이 부르는 비용 사고 — 패턴마다 다른 종료 조건과 폭주 상한

프로덕션 준비도 비교

장애 복원력·관측 가능성·재현성·수평 확장·디버깅 — 상태를 저장하는 Workflow가 복원력·재현성 우위