onaeonae1

Define/Configure workflowfrom prefect import flow@flowdef my_workflow() -> str: return "Hello, world!"앞서 설명했듯 정의하는 것 자체는 매우 간단하다. 위와 같이 지원되는 함수에 데코레이터를 붙이기만 하면 기본적인 정의는 된다.지원되는 함수 ⇒ 일반 함수, classmethod, instance_method, generator, …Flow Configurationflow 를 정의할 때 decorator 에 넣어줄 수 있는 configuration 은 다음과 같다.참고로 모두 optional 이다.descriptionname → flow 의 이름retries ⇒ failure 시 재시도를 최대 몇 번이나 할 건지 (기본값..

회사에서 Prefect 를 쓸 일이 생겼다. 본격적인 업무 투입 전 공식문서를 읽고 개념들을 파악해보자. 지난 시간에는 Flow의 개념에 대해서 파악했고, 오늘 알아볼 것은 Task이다. TasksDef) tasks are atomic units of work with transactional semanticsflow 와 비슷하게 decorator 를 사용해서 정의한다from prefect import task@task(log_prints=True)def explain_tasks(): print("run any python code here!") print("but maybe just a little bit")주로 Flow 보다 작은 기능들을 커버할 때 사용된다(thread 같은 거라고 보면 ..

회사에서 prefect 를 쓸 일이 생겼다. 공식 문서를 읽으면서 정리한 것이다. Prefect 의 주요 개념으로는 다음이 존재한다.WorkflowsflowstasksDeploymentsConfigurationAutomationsPrefect Cloud 가 있다.여기서 Flow 부분까지 정리해보자 1. Flowfrom prefect import Flow@flow(log_prints=True)def explain_flows(): print("run python code") ### magic stuff print("encapsulated")Flow 는 Python Function 으로 정의되며, Prefect 에서 관리되는 작업의 기본적인 단위(unit) 임기본적으로 python funct..