Charlie Bini
09/09/2022, 4:15 PMresync
graph contains nodes named compose_queries
, compose_queries_2
, etc
@graph
def execute_query(dynamic_query):
# trunk-ignore(flake8/F841)
data = extract(dynamic_query=dynamic_query)
@graph
def resync():
# log
dynamic_query = compose_queries()
dynamic_query.map(execute_query)
# attendance
dynamic_query = compose_queries()
dynamic_query.map(execute_query)
# storedgrades
dynamic_query = compose_queries()
dynamic_query.map(execute_query)
# pgfinalgrades
dynamic_query = compose_queries()
dynamic_query.map(execute_query)
# assignmentscore
dynamic_query = compose_queries()
dynamic_query.map(execute_query)
owen
09/09/2022, 4:33 PMcompose_queries()
-> compose_queries.alias("my_name")()
should work 🙂Charlie Bini
09/09/2022, 4:36 PM