Running and scheduling workflows
Datamin’s workflows can be triggered in 5 different ways:
Manually on-demand
Both buttons to schedule or run workflow manually are located in the top right corner of the workflow's canvas.
Manual trigger is typical for:
Test workflows, that are used for debugging or testing data sources or destinations
Workflows that don't have any periodical schedule, but need to be run sometimes when a user needs it
After clicking on Run workflow
button a user gets an output that shows the status of every task:
Automatically by a schedule
Scheduling is the most common way of triggering workflows. It can be configured using either a visual interface or if you are familiar with a cronjob format, you can also use this one.
From a metric when its value matches a condition
In each metric, you can define which workflows to execute depending on the value of your metric:
Some of the more detailed examples of metrics can be found here in the list of our use cases. Our library of templates also contains multiple ones, which you can use for configuring your own metrics.
Automatically via API as a webhook.
For example, by Apache Airflow, Jenkins, or any other software that is already used in your company for workflow or pipeline orchestration.
More information about triggering workflows via API can be found in the OAuth Clients and API Endpoints.
In real-time from Kafka
When placed as a first task in a workflow, external_trigger allows you to trigger workflows from your data streaming platforms to make it 100% real-time.
The first data streaming platform we integrate with is Kafka. And the open-source library that can trigger workflows from it is hosted on our Github: https://github.com/datamin-io/kafka-trigger
In real-time from Google Cloud Pub/Sub
Triggering Datamin's workflow from Google Cloud Pub/Sub is as easy as just triggering it via API.
You need to create an OAuth Client, and then use it together with the client ID and client secret in the Endpoint URL field of the subscription form of the Cloud Pub/Sub.
[GET/POST] https://api.datamin.io/v1/oauth/token?client_id=%%CLIENT_ID%%&client_secret=%%CLIENT_SECRET%%&grant_type=client_credentials
Last updated