An Apache Airflow provider for all Google services. Contains namespaces and modules for a variety of services, including Google Cloud, Google Ads, and GSuite.
Quick Install
Available Modules
Modules are Python callables available from this provider package.
Types:
OperatorsHooksTransfersSensorsSecretsLogUpdates an existing entry.
Gets a tag template.
Renames a field in a tag template.
Get an entry by target resource name.
Searches Data Catalog for multiple resources like entries, tags that match a query.
Updates a tag template.
Lists the tags on an Entry.
Updates an existing tag.
Start a Java Cloud Dataflow batch job. The parameters of the operation will be passed to the job.
Starts Dataflow SQL query.
Updates a field in a tag template. This method cannot be used to update the field type.
Start a Templated Cloud Dataflow job. The parameters of the operation will be passed to the job.
Starts flex templates with the Dataflow pipeline.
Hook for Google Search Ads 360.
Abstract base operator for Google Compute Engine operators to inherit from.
Hook for Google Compute Engine APIs.
Synchronizes an Azure Data Lake Storage path with a GCS bucket
Perform a batch prediction on Google Cloud AutoML.
Delete Google Cloud AutoML model.
Get Google Cloud AutoML model.
Creates a Google Cloud AutoML dataset.
Deletes a dataset and all of its contents.
Deploys a model. If a model is already deployed, deploying it with the same parameters has no effect. Deploying with different parameters (as e.g. cha…
Runs prediction operation on Google Cloud AutoML.
Imports data to a Google Cloud AutoML dataset.
Updates a dataset.
Creates Google Cloud AutoML model.
Lists table specs in a dataset.
Performs checks against BigQuery. The BigQueryCheckOperator expects a sql query that will return a single row. Each value on that first row is evaluat…
This operator is used to create new dataset for your Project in BigQuery. https://cloud.google.com/bigquery/docs/reference/rest/v2/datasets#resource
Creates a new data transfer configuration.
Synchronizes a Azure FileShare directory content (excluding subdirectories), possibly filtered by a prefix, with a Google Cloud Storage destination pa…
Creates a new external table in the dataset with the data from Google Cloud Storage.
Waits for Data Transfer Service run to complete.
Deletes transfer configuration.
Deletes BigQuery tables
Gets the details of a specific Memcached instance.
Creates a new Cloud SQL instance. If an instance with the same name exists, no action will be taken and the operator will succeed.
Deletes a database from a Cloud SQL instance.
Deletes a specific Memcached instance. Instance stops serving and data is deleted.
Lists AutoML Datasets in project.
Checks that the values of metrics given as SQL expressions are within a certain tolerance of the ones from days_back before.
Deletes a Cloud SQL instance.
Checks for the existence of a table in Google Bigquery.
Checks for the existence of a partition within a table in Google Bigquery.
Transfers a BigQuery table to a Google Cloud Storage bucket.
Upsert BigQuery table
Fetches the data from a BigQuery table (alternatively fetch data for selected columns) and insert that data into a MySQL table.
This operator is used to update table for your Project in BigQuery. Use fields to specify which fields of table to update. If a field is listed in fie…
Performs a simple value check using sql code.
Creates a new Cloud Bigtable instance. If the Cloud Bigtable instance with the given ID exists, the operator does not compare its configuration and im…
Hook for Google Dataflow.
Creates the table in the Cloud Bigtable instance.
Performs DML or DDL query on an existing Cloud Sql instance. It optionally uses cloud-sql-proxy to establish secure connection with the database.
Copies data from one BigQuery table to another.
This operator is used to patch dataset for your Project in BigQuery. It only replaces fields that are provided in the submitted dataset resource.
Hook for Google Cloud Bigtable APIs.
Sensor that waits for Cloud Bigtable table to be fully replicated to its clusters. No exception will be raised if the instance or the table does not e…
Creates a new, empty table in the specified BigQuery dataset, optionally with schema.
Updates a Cloud Bigtable cluster.
Copy data from Cassandra to Google Cloud Storage in JSON format
Hook for Google Bigquery Transfer API.
This operator is used to update dataset for your Project in BigQuery. Use fields to specify which fields of dataset to update. If a field is listed in…
Start manual transfer runs to be executed now with schedule_time equal to current time. The transfer runs can be created for a time range where the ru…
Starts a build with the specified configuration.
Creates a new database inside a Cloud SQL instance.
Hook for the Google Cloud Build Service.
Creates a new job to inspect storage or calculate risk metrics.
Google Cloud AutoML hook.
Creates a DeidentifyTemplate for re-using frequently used configuration for de-identifying content, images, and storage.
Creates an InspectTemplate for re-using frequently used configuration for inspecting content, images, and storage.
Starts asynchronous cancellation on a long-running DlpJob.
Serves DB connection configuration for Google Cloud SQL (Connections of gcpcloudsqldb:// type).
This operator deletes an existing dataset from your Project in Big query. https://cloud.google.com/bigquery/docs/reference/rest/v2/datasets/delete
Creates a job trigger to run DLP actions such as scanning storage for sensitive information on a set schedule.
De-identifies potentially sensitive info from a ContentItem. This method has limits on input size and output size.
Deletes a long-running DlpJob. This method indicates that the client is no longer interested in the DlpJob result. The job will be cancelled if possib…
Executes BigQuery SQL queries in a specific BigQuery database. This operator does not assert idempotency.
Fetches the data from a BigQuery table (alternatively fetch data for selected columns) and returns data in a python list. The number of elements in th…
This operator is used to return the dataset specified by dataset_id.
Updates an existing Cloud Bigtable instance.
Executes a BigQuery job. Waits for the job to complete and returns job id. This operator work in the following way:
Deletes a DeidentifyTemplate.
Deletes the Cloud Bigtable instance, including its clusters and all related tables.
Hook for Google DataFusion.
Deletes the Cloud Bigtable table.
Deletes a job trigger.
Deletes an InspectTemplate.
This operator retrieves the list of tables in the specified dataset.
Gets the latest state of a long-running DlpJob.
Gets a DeidentifyTemplate.
Gets a job trigger.
Gets a stored infoType.
Gets an InspectTemplate.
Lists DlpJobs that match the specified filter in the request.
Finds potentially sensitive info in content. This method has limits on input size, processing time, and output size.
Lists DeidentifyTemplates.
Returns a list of the sensitive information types that the DLP API supports.
Creates a pre-built stored infoType to be used for inspection.
Lists column specs in a table.
Lists stored infoTypes.
Redacts potentially sensitive info from an image. This method has limits on input size, processing time, and output size.
Hook for Google Storage Transfer Service.
Interact with BigQuery. This hook uses the Google Cloud connection.
Updates the metadata and configuration of a specific Redis instance.
locations.
Hook for Google Cloud Natural Language Service.
Updates the metadata and configuration of a specific Memcached instance.
parameters, it must be followed by apply_parameters to apply the parameters to nodes of the Memcached Instance.
Exports data from a Cloud SQL instance to a Cloud Storage bucket as a SQL dump or CSV file.
Abstract base operator for Google Cloud SQL operators to inherit from.
Create a jobGroup, which launches the specified job as the authenticated user. This performs the same action as clicking on the Run Job button in the …
Creates new workflow template.
Deletes a cluster in a project.
Re-identifies content that has been de-identified.
Updates the DeidentifyTemplate.
Deletes a queue from Cloud Tasks, even if it has tasks in it.
Lists the tasks in Cloud Tasks.
Creates a new model.
Hook for Google Cloud Data Loss Prevention (DLP) APIs. Cloud DLP allows clients to detect the presence of Personally Identifiable Information (PII) an…
Gets a queue from Cloud Tasks.
Synthesizes text to speech and stores it in Google Cloud Storage
Lists InspectTemplates.
Updates the InspectTemplate.
Creates an EntryGroup.
Updates the stored infoType by creating a new version.
Hook for Google Cloud Data Catalog Service.
Creates a new Data Fusion instance in the specified project and location.
Export Redis instance data into a Redis RDB format file in Cloud Storage. In next step, deletes a this instance.
Creates a Cloud Data Fusion pipeline.
Updates the metadata and configuration of a specific Redis instance.
Deletes a Cloud Data Fusion pipeline.
Gets an entry.
Lists Cloud Data Fusion pipelines.
Restart a single Data Fusion instance. At the end of an operation instance is fully restarted.
Hook for Google Cloud Text to Speech API.
Stops a Cloud Data Fusion pipeline. Works for both batch and stream pipelines.
Gets details of a single Data Fusion instance.
Create a new cluster on Google Cloud Dataproc. The operator will wait until the creation is successful or an error occurs in the creation process. If …
Delete a transfer job. This is a soft delete. After a transfer job is deleted, the job and all the transfer executions are subject to garbage collecti…
Copies objects from a bucket to another using the Google Cloud Storage Transfer Service.
Gets the latest state of a long-running operation in Google Storage Transfer Service.
Waits for at least one operation belonging to the job to have the expected status.
Pauses a transfer operation in Google Storage Transfer Service.
Uploads a file or list of files to Google Cloud Storage. Optionally can compress the file for upload.
Allocate IDs for incomplete keys. Return list of keys.
Creates a transfer job that runs periodically.
Commit a transaction, optionally creating, deleting or modifying some entities.
Deletes the long-running operation.
Lists long-running operations in Google Storage Transfer Service that match the specified filter.
Gets the latest state of a long-running operation.
Import entities from Cloud Storage to Google Cloud Datastore
Updates a transfer job that runs periodically.
Roll back a transaction.
Deletes a single Date Fusion instance.
Run a query for entities. Returns the batch of query results.
Exports a copy of all or a subset of documents from Google Cloud Firestore to another storage system, such as Google Cloud Storage.
Creates a function in Google Cloud Functions. If a function with this name already exists, it will be updated.
Hook for Google Cloud Key Management service.
Cancels a transfer operation in Google Storage Transfer Service.
Hook for the Google Cloud Functions APIs.
Hook for Google Cloud Memorystore for Memcached service APIs.
Hook to connect to a remote instance in compute engine
Hook for Google Cloud Dataproc APIs.
Lists job triggers.
Hook for Google GCP APIs.
Synchronizes an S3 bucket with a Google Cloud Storage bucket using the Google Cloud Storage Transfer Service.
Copies the instance template, applying specified changes.
Patches the Instance Group Manager, replacing source template URL with the destination one. API V1 does not have update/patch operations for Instance …
Starts a Cloud Data Fusion pipeline. Works for both batch and stream pipelines.
Launching Cloud Dataflow jobs written in python. Note that both dataflow_default_options and options will be merged to specify pipeline execution para…
Export entities from Google Cloud Datastore to Cloud Storage
Updates a single Data Fusion instance.
Start a Hadoop Job on a Cloud DataProc cluster.
Start a Spark Job on a Cloud DataProc cluster.
Instantiate a WorkflowTemplate on Google Cloud Dataproc. The operator will wait until the WorkflowTemplate is finished executing.
Synchronizes the contents of the buckets or bucket’s directories in the Google Cloud Services.
Deletes the specified function from Google Cloud Functions.
List all objects from the bucket with the given string prefix and delimiter in name.
Deletes bucket from a Google Cloud Storage.
Deletes objects from a Google Cloud Storage bucket, either from an explicit list of object names or all objects matching a prefix.
Finds named entities in the text along with entity types, salience, mentions for each entity, and other properties.
Deletes a Cloud Spanner database.
Disables one or more enabled alerting policies identified by filter parameter. Inoperative in case the policy is already disabled.
Creates a new Cloud Spanner instance, or if an instance with the same instance_id exists in the specified project, updates the Cloud Spanner instance.
Adds a Product to the specified ProductSet. If the Product is already present, no change is made.
Purges a queue by deleting all of its tasks from Cloud Tasks.
Pauses a queue in Cloud Tasks.
Performs video annotation, annotating video shots.
Checks the metrics of a job in Google Cloud Dataflow.
Returns a list of executions which belong to the workflow with the given name. The method returns executions of all workflow revisions. Returned execu…
Lists Workflows in a given project and location. The default order is not specified.
Fetches the results from the Facebook Ads API as desired in the params Converts and saves the data as a temporary JSON file Uploads the JSON to Google…
Checks for the existence of GCS objects at a given prefix, passing matches via XCom.
Checks for the existence of a file in Google Cloud Storage.
A base hook for Google cloud-related hooks. Google cloud has a shared REST API client that is built in the same way no matter which service you use. T…
Checks if an object is updated in Google Cloud Storage.
Creates a Redis instance based on the specified tier and memory size and import a Redis RDB snapshot file from Cloud Storage into a this instance.
Copy data from TrinoDB to Google Cloud Storage in JSON or CSV format.
Begins a new transaction. Returns a transaction handle.
Hook for Google Cloud Memorystore APIs.
Will update current set of Parameters to the set of specified nodes of the Memcached Instance.
Imports data into a Cloud SQL instance from a SQL dump or CSV file in Cloud Storage.
Creates SDF operation task.
Retrieves Connection object from Google Cloud Secrets Manager
Recognizes speech from audio file and returns it as text.
Creates a queue in Cloud Tasks.
Copies objects from a Google Cloud Storage service to a Google Drive service, with renaming if requested.
Updates settings of a Cloud SQL instance.
Performs video annotation, annotating explicit content.
Deletes a task from Cloud Tasks.
Creates a new ProductSet resource.
Instantiate a WorkflowTemplate Inline on Google Cloud Dataproc. The operator will wait until the WorkflowTemplate is finished executing.
Submits a job to a cluster.
Checks for the job autoscaling event in Google Cloud Dataflow.
Checks for the job message in Google Cloud Dataflow.
Removes a Product from the specified ProductSet.
Export Redis instance data into a Redis RDB format file in Cloud Storage.
GCSTaskHandler is a python log handler that handles and reads task instance logs. It extends airflow FileTaskHandler and uploads to and reads from GCS…
Initiates a failover of the primary node to current replica node for a specific STANDARD tier Cloud Memorystore for Redis instance.
Determines a list of objects that were added or modified at a GCS source location during a specific time-span, copies them to a temporary location on …
This class is deprecated. Please use airflow.providers.google.cloud.sensors.gcs.GCSObjectsWithPrefixExistenceSensor.
Loads files from Google Cloud Storage into BigQuery.
Downloads a file from Google Cloud Storage.
Checks for changes in the number of objects at prefix in Google Cloud Storage bucket and returns True if the inactivity period has passed with no incr…
Create a Google Kubernetes Engine Cluster of specified dimensions The operator will wait until the cluster is created.
Executes a task in a Kubernetes pod in the specified Google Kubernetes Engine cluster
Interact with Google Sheets via Google Cloud connection Reading and writing cells in Google Sheet: https://developers.google.com/sheets/api/guides/val…
Fetches the daily results from the Google Ads API for 1-n clients Converts and saves the data as a temporary CSV file Uploads the CSV to Google Cloud …
Take a file from Cloud Storage and uploads it to GA via data import API.
Hook for the Google Ads API.
Hook for Google Analytics 360.
Fetches all the Notification Channels identified by the filter passed as filter parameter. The desired return type can be specified by the format para…
Creates a new alert or updates an existing policy identified the name field in the alerts parameter.
Gets the details of a specific Redis instance.
Returns a web property-Google Ads link to which the user has access.
Deletes a specific Redis instance. Instance stops serving and data is deleted.
Fetches all the Alert Policies identified by the filter passed as filter parameter. The desired return type can be specified by the format parameter, …
Copies objects from a bucket to another, with renaming if requested.
Deletes a stored infoType.
Transfer files from a Google Cloud Storage bucket to SFTP server.
Interact with Google Cloud Datastore. This hook uses the Google Cloud connection.
Hook for Google Kubernetes Engine APIs.
Lists webProperty-Google Ads links for a given web property
Writes Google Sheet data into Google Cloud Storage.
Inserts conversions.
Updates existing conversions.
Saves list of customers on GCS in form of a csv file.
Deletes a report by its ID.
Hook for Google Campaign Manager.
Retrieves a report and uploads it to GCS bucket.
Creates a report.
Deletes previous GA uploads to leave the latest file to control the size of the Data Set Quota.
Hook for connection with Dataprep API. To get connection Dataprep with Airflow you need Dataprep token. https://clouddataprep.com/documentation/api#se…
Interact with Google Cloud Deployment Manager using the Google Cloud connection. This allows for scheduled and programmatic inspection and deletion fo…
Check if report is ready.
GA has a very particular naming convention for Data Import. Ability to prefix “ga:” to all column headers and also a dict to rename columns to match t…
A hook to use the Google API Discovery Service.
Retrieves a stored query.
Creates a query.
Retrieves line items in CSV format.
Deletes a stored query as well as the associated stored reports.
Sensor for detecting the completion of SDF operation.
Hook for Google Display & Video 360.
Returns an execution for the given workflow_id and execution_id.
Updates an existing workflow. Running this method has no impact on already running executions of the workflow. A new revision of the workflow may be c…
Deletes a tag.
Deletes an existing entry.
Sensor for detecting the completion of DV360 reports.
Gets details of a single Workflow.
Writes a Google Drive file into local Storage.
Uploads .csv file from Google Cloud Storage to provided Google Spreadsheet.
Lists all accounts to which the user has access.
Creates a tag on an entry.
Creates an entry.
Synchronizes an S3 key, possibly a prefix, with a Google Cloud Storage destination path.
Pulls messages from a PubSub subscription and passes them through XCom. Always waits for at least one message to be returned from the subscription.
Transfer files to Google Cloud Storage from SFTP server.
Publish messages to a PubSub topic.
Runs a report.
Create a PubSub subscription.
Copy data from PrestoDB to Google Cloud Storage in JSON or CSV format.
Copy data from Microsoft SQL Server to Google Cloud Storage in JSON or CSV format.
Operator for cleaning up failed MLEngine training job.
Operator for launching a MLEngine training job.
Pulls messages from a PubSub subscription and passes them through XCom. If the queue is empty, returns empty list - never waits for messages. If you d…
Lists all available versions of the model
_BigQueryDbHookMixin
Execute command in LevelDB
Exception specific for LevelDB
Hook for accessing Google Pub/Sub.
Hook for the Google Drive APIs.
Deletes an EntryGroup.
Creates a tag template.
Creates a field in a tag template.
Download SDF media and save it in the Google Cloud Storage.
Deletes the cluster, including the Kubernetes endpoint and all worker nodes.
Updates a job trigger.
Checks for the existence of a file in Google Cloud Storage.
Hook for Google Cloud SQL APIs.
The base class for operators that launch job on DataProc.
Check for the state of a previously submitted Dataproc job.
Scale, up or down, a cluster on Google Cloud Dataproc. The operator will wait until the cluster is re-scaled.
Detects Text in the image
Gets information associated with a Product.
Gets information associated with a ProductSet.
Detects Document Text in the image
Creates a new ACL entry on the specified object.
Copies data from a source GCS location to a temporary location on the local filesystem. Runs a transformation on this file as specified by the transfo…
Interact with Google Cloud Storage. This hook uses the Google Cloud connection.
Creates a new bucket. Google Cloud Storage uses a flat namespace, so you can’t create a bucket with a name that is already in use.
Start a Spark SQL query Job on a Cloud DataProc cluster.
Updates a cluster in a project.
Creates a new ACL entry on the specified bucket.
Start a PySpark Job on a Cloud DataProc cluster.
Start a Pig query Job on a Cloud DataProc cluster. The parameters of the operation will be passed to the cluster.
Start a Hive query Job on a Cloud DataProc cluster.
Makes changes to a Product resource. Only the display_name, description, and labels fields can be updated right now.
Detects Document Text in the image
Run image detection and annotation for an image or a batch of images.
Get information about the batch jobs within a Cloud Dataprep job. API documentation https://clouddataprep.com/documentation/api#section/Overview
Hook for Google Cloud Vision APIs.
Creates and returns a new product resource.
Hook for Google Cloud Video Intelligence APIs.
Performs video annotation, annotating video labels.
Hook for Google Cloud translate APIs.
Gets a task from Cloud Tasks.
Recognizes speech in audio input and translates it.
Translate a string or list of strings.
Forces to run a task in Cloud Tasks.
Lists queues from Cloud Tasks.
Updates a queue in Cloud Tasks.
Creates a task in Cloud Tasks.
Hook for Google Cloud Tasks APIs. Cloud Tasks allows developers to manage the execution of background work in their applications.
Resumes a queue in Cloud Tasks.
Hook for Google Cloud Speech API.
Updates a resource containing information about a database inside a Cloud SQL instance using patch semantics. See: https://cloud.google.com/sql/docs/m…
Classifies a document into categories.
Analyzes the sentiment of the provided text.
Finds entities, similar to AnalyzeEntities in the text and analyzes sentiment associated with each entity and its mentions.
Creates a Memcached instance based on the specified tier and memory size.
Lists all Redis instances owned by a project in either the specified location (region) or all locations.
Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.
Creates a Redis instance based on the specified tier and memory size.
Invokes a deployed Cloud Function. To be used for testing purposes as very limited traffic is allowed.
Resumes a transfer operation in Google Storage Transfer Service.
Checks state of an execution for the given workflow_id and execution_id.
Cancels an execution using the given workflow_id and execution_id.
Creates a new workflow. If a workflow with the specified name already exists in the specified project and location, the long running operation will re…
Creates a new execution using the latest revision of the given workflow.
Deletes a workflow with the specified name. This method also cancels and deletes all running executions of the workflow.
Stackdriver Hook for connecting with Google Cloud Stackdriver
Enables one or more disabled alerting policies identified by filter parameter. Inoperative in case the policy is already enabled.
Enables one or more disabled alerting policies identified by filter parameter. Inoperative in case the policy is already enabled.
Deletes a notification channel.
Executes an arbitrary DML query (INSERT, UPDATE, DELETE).
Deletes an alerting policy.
Creates a new Cloud Spanner database, or if database exists, the operator does nothing.
Copy data from Postgres to Google Cloud Storage in JSON or CSV format.
Create a PubSub topic.
Sets a version in the model.
Hook for Google ML Engine APIs.
Operator for managing a Google Cloud ML Engine model.
Hook for Google OS login APIs.
Operator for managing a Google Cloud ML Engine version.
Runs a Life Sciences Pipeline
Detects Document Text in the image
Deletes a ReferenceImage ID resource.
Permanently deletes a product and its reference images.
Creates and returns a new ReferenceImage ID resource.
Copy data from Oracle to Google Cloud Storage in JSON or CSV format.
Deletes a tag template and all tags using the template.
Permanently deletes a ProductSet. Products and ReferenceImages in the ProductSet are not deleted. The actual image files are not deleted from Google C…
Delete a PubSub subscription.
Creates a new notification or updates an existing notification channel identified the name field in the alerts parameter.
Start a Google Cloud ML Engine prediction job.
Copy data from MySQL to Google Cloud Storage in JSON or CSV format.
Updates a Cloud Spanner database with the specified DDL statement.
Gets a particular model
Deletes the version from the model.
Deletes a model.
Creates a new version in the model
Uploads line items in CSV format.
Deletes a Cloud Spanner instance. If an instance does not exist, no action is taken and the operator succeeds.
Runs a stored query to generate a report.
Checks for the status of a job in Google Cloud Dataflow.
Stops an instance in Google Compute Engine.
Starts an instance in Google Compute Engine.
Makes changes to a ProductSet resource. Only display_name can be updated currently.
Get the specified job group. A job group is a job that is executed from a specific node in a flow. API documentation https://clouddataprep.com/documen…
the request.
Hook for the Google Secret Manager API.
Hook for Google Cloud Spanner APIs.
Submits Salesforce query and uploads results to Google Cloud Storage
Disables one or more enabled notification channels identified by filter parameter. Inoperative in case the policy is already disabled.
Gets an entry group.
Delete a PubSub topic.
Hook for the Google Cloud Life Sciences APIs.
Creates a new spreadsheet.
Plyvel Wrapper to Interact With LevelDB Database LevelDB Connection Documentation
Downloads a report to GCS bucket.
Polls for the status of a report request.
Writes a Google Drive file into Google Cloud Storage.
Hook for the Google Firestore APIs.
Deletes a field in a tag template and all uses of that field.
Inserts a report request into the reporting system.
Class with Google Cloud Transfer operations statuses.
Copy data from SQL to Google Cloud Storage in JSON or CSV format.
Update BigQuery Table Schema Updates fields on a table schema based on contents of the supplied schema_fields_updates parameter. The supplied schema d…
Fetches the data from a BigQuery table (alternatively fetch data for selected columns) and insert that data into a MSSQL table.
Check the status of the pipeline in the Google Cloud Data Fusion
Copy data from SQL results to provided Google Spreadsheet.
Updates a BuildTrigger by its project ID and trigger ID.
Lists existing BuildTriggers.
Returns information about a previously requested build.
Returns information about a BuildTrigger.
Lists previously requested builds.
Creates a new build based on the specified build. This method creates a new build using the original build request, which may or may not result in an …
Runs a BuildTrigger at a particular source revision.
Creates a new BuildTrigger.
Deletes a BuildTrigger by its project ID and trigger ID.
Cancels a build in progress.