phanikumv commented on code in PR #67021:
URL: https://github.com/apache/airflow/pull/67021#discussion_r3252075142
##########
providers/google/src/airflow/providers/google/cloud/operators/cloud_batch.py:
##########
@@ -76,7 +77,9 @@ def __init__(
self.project_id = project_id
self.region = region
self.job_name = job_name
- self.job = job
+ # Normalize Job protobuf to dict so Airflow's template renderer can
descend
+ # into nested fields (e.g. runnable.container.commands). See #37217.
+ self.job = Job.to_dict(job) if isinstance(job, Job) else job
Review Comment:
```suggestion
# Normalize Job protobuf to dict so Airflow's template renderer
can descend
# into nested fields (e.g. runnable.container.commands). See
#37217.
if isinstance(job, Job):
job = Job.to_dict(job)
self.job = 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]
