Skip to main content

All Questions

0 votes
1 answer
254 views

How to access Kubernetes Service via API in Cloud Composer

I am trying to send an API request to a Kubernetes Service using Cloud Composer. I have the following snippet: def fetchToken(): ... def start_application(): keycloak_token = fetchToken() url = &...
emilk's user avatar
  • 106
1 vote
1 answer
2k views

Configure volumes in airflow GKEStartPodOperator operator

I have a google cloud composer environment. In my DAG I want to create a pod in GKE. When I come to deploy a simple app based on a docker container that doesn't need any volume configuration or ...
Idhem's user avatar
  • 964
1 vote
0 answers
631 views

Triggering a GKE CronJob workload from cloud composer

I have a google cloud composer environment running. In this composer I want to orchestrate the execution of a GKE CronJob workload, and a google dataflow job. For the dataflow job part, I came to run ...
Idhem's user avatar
  • 964
1 vote
0 answers
399 views

google.cloud.container_v1.types.Cluster: using node_pools

I need to create a cluster using GKECreateClusterOperator in airflow 2.0.1. I need to create this cluster with a node pool other than the default. This operator receives an object of type google.cloud....
Rafael Ribeiro's user avatar