test_master_pipeline_e2e.py

# Trigger the Master Pipeline for Processed to Curated Zone
masterpipeline_curated_params = {
    "lookUpTables": [{
                    "SourceTableSchemaName":"dbo",
                    "SourceTableName":table_processed,
                    "SinkTableSchemaName":"dbo",
                    "SinkTableName": table_curated,
                    "HasIncrementalData":"false"
                    }],
    "sourceDatabase": database,
}

pipeline_name = constants.COPY_TO_DEDICATE_SQL_PIPELINE

print(f"{pipeline_name} Parameters : {masterpipeline_curated_params}\n")

pipeline_run_result = pipelineutils.run_and_observe_pipeline(
    azure_credential, synapse_endpoint, pipeline_name, masterpipeline_curated_params)