Skip to content

Trigger windmill workflow from Port using self-service actions and Kafka

Notifications You must be signed in to change notification settings

trivago/trigger-windmill-workflow

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

4 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Triggering Windmill Workflows

Getting started

The following example helps internal developer teams to trigger Windmill jobs and workflows using Port's self service actions. In particular, you will create a blueprint for windmillJobs that will be connected to a backend action. You will then add some python script (app.py) to read from a Kafka topic and trigger your Windmill workflow.

Job blueprint

Create the Windmill job blueprint in Port using this json file

Create action UI

Use the action schema in this json file to setup the action UI

Variables

The list of required variables to run the backend code in app.py are:

  • KAFKA_CONSUMER_BROKERS
  • KAFKA_CONSUMER_USERNAME
  • KAFKA_CONSUMER_PASSWORD
  • KAFKA_CONSUMER_GROUP_ID
  • KAFKA_CONSUMER_CLIENT_ID
  • WINDMILL_API_TOKEN
  • PORT_CLIENT_ID
  • PORT_CLIENT_SECRET

Run action

Run this action with some input

{
    "workspace": "demo",
    "file_path": "f/examples/ban_user_example",
    "job_data": {
        "value": "wonderwoman",
        "reason": "First Attempt at webhook",
        "database": "$res:f/examples/demo_windmillshowcases",
        "username": "Jack",
        "slack_channel": "bans"
    }
}

About

Trigger windmill workflow from Port using self-service actions and Kafka

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Python 100.0%