wiretrack
12/24/2020, 8:18 PMcustomer_flow = Flow('customer_flow')
customer_flow.register(project_name="All Flows")
customer_uptodate = check_status(source='db.sqlite3', target='db_target.sqlite3', table='customers')
test_target_db = test_target_db()
test_source_db = test_source_db()
customer_flow.add_task(test_source_db)
customer_flow.add_task(test_target_db)
customer_flow.add_task(customer_uptodate)
I get the error “ValueError: Could not infer an active Flow context.” (edited)
but I couldn’t understand what exactly i’m doing wrong using the imperative API. registered the flow, registerd the tasks, add_task to flow. i didn’t understand what could I do differently, since the error appears right at my first task (customer_uptodate = check_status(source=‘db.sqlite3’, target=‘db_target.sqlite3’, table=‘customers’)