Get hands-on experience with 20+ free Google Cloud products and $300 in free credit for new customers.

Batch Job + Composer (Airflow) + Python

Hi all,

I'm trying to set up an environment for the Cloud Composer. The goal is to have airflow tasks start batch jobs, and wait for them to finish. Unfortunately, google.cloud.batch_v1 (version 0.9.0) depends on proto-plus==1.22.0, while composer-2.1.10-airflow-2.4.3 needs proto-plus==1.19.6 . So I cannot update the environment to add the needed package. Does anyone know a work-around?

0 2 521
2 REPLIES 2

Google Cloud has a new Batch service that processes batch jobs. You may want to check it out as it may be helpful for your use case.

Thank you Joevanie. That's exactly the service I'm asking about. It has a python API that I'd like to use in conjunction with Cloud Composer. But its python package depends on proto-plus==1.22.0, while the Cloud Composer environment needs proto-plus==1.19.6 . So currently I don't know how to use the two together. My question was whether there is any way around this issue. If there is no work-around now, does anyone know whether future releases will solve this issue? And if so, how soon?