def run_pipeline(update_from=None):
    if update_from is None:
        update_from = (
            (datetime.now() - relativedelta(hours=8)).isoformat()
            # "2019-10-01T11:41:00.160867"
        )
    return execute_pipeline(
        feature_update_pipeline,
        environment_dict={
            "solids": {
                "case_files_table_changed": {
                    "inputs": {
                        "params": {"value": {"last_update_at": update_from}},
                    }
                },
                "new_payments": {
                    "inputs": {
                        "params": {"value": {"last_update_at": update_from}},
                    }
                },
                "changed_addresses": {
                    "inputs": {
                        "params": {"value": {"last_update_at": update_from}},
                    }
                },}}