Skip to content

Instantly share code, notes, and snippets.

@esenthil2018
Created May 28, 2022 02:36
Show Gist options
  • Save esenthil2018/a12b031f019e7f498ece56e8cc9c3858 to your computer and use it in GitHub Desktop.
Save esenthil2018/a12b031f019e7f498ece56e8cc9c3858 to your computer and use it in GitHub Desktop.
lp5.py
import os
directory = lineapy.to_pipeline(
[train_art.name,y_art.name, model_art.name],
framework = 'AIRFLOW',
pipeline_name = "dnn_pipeline",
dependencies = {'dnn_pipeline_dnn_model':{'dnn_pipeline_train_data','dnn_pipeline_y'}},
output_dir = os.environ.get("AIRFLOW_HOME","~/airflow")+"/dags")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment