dacort commented on code in PR #31169:
URL: https://github.com/apache/airflow/pull/31169#discussion_r1192636604
##########
airflow/providers/amazon/aws/operators/emr.py:
##########
@@ -1035,14 +1036,15 @@ def execute(self, context: Context) -> dict:
if response["ResponseMetadata"]["HTTPStatusCode"] != 200:
raise AirflowException(f"EMR serverless job failed to start:
{response}")
- self.log.info("EMR serverless job started: %s", response["jobRunId"])
+ self.job_id = response["jobRunId"]
+ self.log.info("EMR serverless job started: %s", self.job_id)
if self.wait_for_completion:
# This should be replaced with a boto waiter when available.
Review Comment:
*nod* Makes sense. There are some other generic messages like `Received
SIGTERM. Terminating subproces`, but it would be nice to let folks know what's
happening specific to the job.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
