def METHOD_NAME(self, context):
    self.run_id = self.hook.launch_run(
        repository_name=self.repository_name,
        repostitory_location_name=self.repostitory_location_name,
        job_name=self.job_name,
        run_config=self.run_config,
    )
    # save relevant info in xcom for use in links
    context["task_instance"].xcom_push(key="run_id", value=self.run_id)
    context["task_instance"].xcom_push(
        key="organization_id",
        value=self.hook.organization_id if self.dagster_conn_id else self.organization_id,
    )
    context["task_instance"].xcom_push(
        key="deployment_name",
        value=self.hook.deployment_name if self.dagster_conn_id else self.deployment_name,
    )
    self.log.info("Run Starting....")
    self.log.info(
        "Run tracking: %s",
        LINK_FMT.format(
            organization_id=self.hook.organization_id,
            deployment_name=self.hook.deployment_name,
            run_id=self.run_id,
        ),
    )
    self.hook.wait_for_run(
        run_id=self.run_id,
    )