Query icon
Publish icon
MailSend icon
gcp icon
Schedule icon

Publish Pipeline Completion Events to Pub/Sub

Run a scheduled BigQuery aggregation, then publish a structured completion event to a Google Cloud Pub/Sub topic so downstream services and Kestra flows react in real time.

Categories
CloudData

More Cloud Blueprints

Glue ETL, Athena Validation, DynamoDB Cache
StartJobRun icon
Query icon
PutItem icon
SlackIncomingWebhook icon
Schedule icon
CloudData
High-Performance Computing, Run Parallel Python Workloads on AWS Batch with ECS Fargate
WorkingDirectory icon
Clone icon
TerraformCLI icon
Script icon
Docker icon
Parallel icon
+2
CloudCoreInfrastructure
Autoscale EMR Serverless Spark on a CloudWatch Backlog
Query icon
If icon
StartServerlessJobRun icon
SlackIncomingWebhook icon
Schedule icon
CloudData

More Data Blueprints

Trigger an Airflow DAG
TriggerDagRun icon
Data
Build an ETL Pipeline with Parallel Airbyte Syncs and dbt Core Transformations
Parallel icon
Sync icon
WorkingDirectory icon
Clone icon
Build icon
Docker icon
Data
AI-Powered Inventory Demand Forecasting, Auto-Generate Purchase Orders with OpenAI
Parallel icon
Request icon
ChatCompletion icon
Script icon
If icon
ForEach icon
+3
AIBusinessData
See How

New to Kestra?

Use blueprints to kickstart your first workflows.

Get Started