Skip to content

Instantly share code, notes, and snippets.

@kshitijcode

kshitijcode/successandassert

Created November 30, 2021 04:32
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save kshitijcode/115b69a32d7ff5bbdaa5eb95db54514b to your computer and use it in GitHub Desktop.
Save kshitijcode/115b69a32d7ff5bbdaa5eb95db54514b to your computer and use it in GitHub Desktop.
Download ZIP
Raw
successandassert
pipeline_run_result = pipelineutils.run_and_observe_pipeline(
azure_credential, synapse_endpoint, pipeline_name, masterpipeline_processed_params)
assert pipeline_run_result == constants.PIPELINE_SUCCESS_STATUS
# Check for Data in processed Zone
cursor = sql_connection_client.cursor()
cursor.execute(
"SELECT COUNT(*) AS COUNT FROM [dbo].[{0}]".format(table_processed))
row = cursor.fetchone()
assert row is not None
assert int(row.COUNT) >=1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment