def METHOD_NAME(event):
    assert event.run.facets["parent"].run["runId"] == TASK_UUID
    assert event.run.facets["parent"].job["name"] == "TestDBTCloudExtractor.task_id"
    assert event.job.namespace == "default"
    assert event.job.name.startswith("SANDBOX.TEST_SCHEMA.my_new_project")
    if len(event.inputs) > 0:
        assert (
            event.inputs[0].facets["dataSource"].name
            == "snowflake://gp21411.us-east-1.aws"
        )
        assert (
            event.inputs[0].facets["dataSource"].uri
            == "snowflake://gp21411.us-east-1.aws"
        )
        assert event.inputs[0].facets["schema"].fields[0].name.upper() == "ID"
        if event.inputs[0].name == "SANDBOX.TEST_SCHEMA.my_first_dbt_model":
            assert event.inputs[0].facets["schema"].fields[0].type.upper() == "NUMBER"
    if len(event.outputs) > 0:
        assert (
            event.outputs[0].facets["dataSource"].name
            == "snowflake://gp21411.us-east-1.aws"
        )
        assert (
            event.outputs[0].facets["dataSource"].uri
            == "snowflake://gp21411.us-east-1.aws"
        )
        assert event.outputs[0].facets["schema"].fields[0].name.upper() == "ID"
        if event.outputs[0].name == "SANDBOX.TEST_SCHEMA.my_first_dbt_model":
            assert event.outputs[0].facets["schema"].fields[0].type.upper() == "NUMBER"