How to execute a Cloud Function after Dataflow job has succeeded?

I want to trigger Cloud Function only if Dataflow job execution completed successfully.

Cloud Function should not be triggered if Dataflow job is failed.

I am running a Dataflow job using a Dataflow template (jdbc to BigQuery) from the the Dataflow UI.

There is no option to trigger any Cloud Function or something after job execution. Also, I can't make changes in template code. What's the way to trigger Cloud Function?

There isn't, yet, built it feature for this, but I can propose a workaround.

• Go to Cloud Logging and go to the advanced filter (or to the new UI)
• Enter this filter

resource.type="dataflow_step"
textPayload="Worker pool stopped."

• Then create a sink (action -> create sink in the new UI)
• Choose PubSub as sink destination (create a new topic for this)
• Save
• Then link the topic to your Cloud Function (either with a push subscription to a HTTP triggered Cloud Functions, or with a Topic Triggered Cloud Functions.

Like this, every end of dataflow job, a new message will be posted to PubSub and your Cloud Function will be triggered.