Manuel Aristarán
03/06/2020, 6:53 PMprefectwith Flow("Salesforce to Cassandra") as f:
    tap_config = Parameter("tap_config")
    tap_catalog = Parameter("tap_catalog")
    target_config = Parameter("target_config")
    salesforce_result = run_salesforce_tap(config=tap_config, catalog=tap_catalog)
    result = run_cassandra_target(config=target_config, input=salesforce_result)