Hi! I am trying to understand how flyte converts t...
# ask-the-community
a
Hi! I am trying to understand how flyte converts the Python workflow into DAG that can be run on airflow / k8s? Any pointers on how Python code is parsed? Is the DAG represented as a proto? Will like to look into running parts of DAG on AWS lambda.
k
It does not run it on airflow
It runs it on its own scheduler engine
The intermediate representation is in protobuf
a
Got it. Thanks. Any code pointers where this intermediate protobuf representation is generated?
k
The flyteidl repo
a
Thanks
k
flyte can compile airflow workflow to Flyte proto, and then run it on the flyte cluster. check out this PR. https://github.com/flyteorg/flytekit/pull/1725