search

Snowflake-Labs / sfguide-data-engineering-with-snowpark-python-intro

Apache License 2.0
18 stars 1.22k forks source link

07_deploy_task_dag.py DAG dependency issue #1

Open alykuna opened 7 months ago

alykuna commented 7 months ago

This appears to be backwards: image It creates a DAG graph where 1 and 2 are dependent on task3

Note Snowflake docs :

. . .
  dag_task2 = DAGTask(
    StoredProcedureCall(
      dosomething, stage_location="@mystage",
      packages=["snowflake-snowpark-python"]
    ),
    warehouse="test_warehouse"
  )
# Shift right and left operators can specify task relationships.
dag_task1 >> dag_task2  # dag_task1 is a predecessor of dag_task2
. . .

Apologies if I've done anything incorrect in here. This is my first :D

alykuna commented 7 months ago

happy to try a PR for it