rawtoprocessed

table_raw = "integrationtest_users"
table_processed = "processed_integrationtest_user"

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

pipeline_name = constants.COPY_TO_DEDICATE_SQL_PIPELINE

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

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