Flyte 실행(Execution)

Flyte 실행(Execution)

실행(execution)은 Flyte에서 태스크·워크플로가 실제로 돌아간 한 번을 가리켜요. 워크플로를 실행하면 그 실행의 상태·입력·출력이 기록되므로, 나중에 결과를 확인하거나 재현할 수 있어요. 실행 단위가 잘 구분되어 있기 때문에 병렬 실행과 상태 추적이 안정적으로 이뤄져요.

출처: Flyte Executions

실행하는 방법

워크플로를 실행하는 방법은 여러 가지예요.

  • 로컬 실행 — 태스크·워크플로 함수를 그대로 호출하거나, python my_example.py처럼 스크립트로 실행해요.
  • pyflyte 로컬 실행 — pyflyte run my_example.py my_workflow --a 1 --b 2 ... 처럼 명령줄에서 실행해요.
  • 원격 실행 — pyflyte run --remote ...로 Flyte 인스턴스에서 실행해요. FLYTECTL_CONFIG 설정이 준비돼 있다고 가정해요.
  • Python에서 원격 실행 — FlyteRemote.execute 메서드를 사용해요.

실행 상태와 이력

워크플로 실행이 시작되면 Flyte가 그 실행의 상태를 추적해요. 어느 태스크가 어떻게 진행됐는지, 몇 단계가 성공했는지, 어떤 데이터가 흘렀는지를 실행 기록에서 확인할 수 있어요. 실행이 실패하면 실패한 지점을 보고 디버깅할 수 있고, 부분적으로 성공한 지점을 기준으로 이어서 다시 실행하는 것도 고려할 수 있어요.

실행 단위인 태스크·워크플로

실행은 태스크 단위로도 이뤄져요. 개별 태스크 하나를 실행하거나, 워크플로 전체를 실행하거나, 상황에 따라 원격에서 시작할 수 있어요. Flyte의 실행 개념이 잘 정의돼 있어서 복잡한 파이프라인도 단계별 상태를 정확히 파악할 수 있어요.

더 알아보기