This page describes what data Cloud Composer stores for your environment in Cloud Storage.
When you create an environment, Cloud Composer creates a
Cloud Storage bucket and associates the bucket
with your environment. The name of the bucket is based on the environment region, name,
and a random ID such as
Cloud Composer stores the source code for your workflows (DAGs) and their dependencies in specific folders in Cloud Storage and uses Cloud Storage FUSE to map the folders to the Airflow instances in your Cloud Composer environment.
Folders in the Cloud Storage bucket
|Folder||Descripton||Storage path||Mapped directory|
|DAG||Stores the DAGs for your environment. Only the DAGs in this folder are scheduled for your environment.||
|Plugins||Stores your custom plugins, such as custom in-house Airflow operators, hooks, sensors, or interfaces.||
|Data||Stores the data that tasks produce and use. This folder is mounted on all worker nodes.||
|Logs||Stores the Airflow logs for tasks. Logs are also available in the Airflow web interface.||
DAGs and plugins: By default, Cloud Composer provisions 100 GB capacity for your environment, the DAGs folder, and the Plugins folder. To avoid workflow failures, only store the DAGs and plugins for your environment in these folders.
Data and logs: The Data folder and Logs folder are not subject to capacity limits. However, to avoid a webserver error, make sure the data the webserver needs to parse a DAG (not run) is available in the DAGs folder. Otherwise, the webserver can't access the data or load the Airflow web interface.
Currently, you cannot change the storage capacity.
When you modify the DAGs or plugins in the Cloud Storage bucket, Cloud Composer synchronizes the data across all the nodes in the cluster. Cloud Composer synchronizes the DAGs and plugins folders uni-directionally by copying locally and synchronizes data and logs folders bi-directionally by using Cloud Storage FUSE.
Data is not synchronized to the webserver because of limited capacity and because the webserver parses but doesn't run DAGs in a Cloud Composer environment. The workers run the DAGs.