Workflow Jobs

curl -X GET \
  https://awx.example.com/api/v2/workflow_jobs/ \
  -H "Authorization: Bearer YOUR_TOKEN"

curl -X GET \
  https://awx.example.com/api/v2/workflow_jobs/50/ \
  -H "Authorization: Bearer YOUR_TOKEN"

curl -X GET \
  https://awx.example.com/api/v2/workflow_jobs/50/workflow_nodes/ \
  -H "Authorization: Bearer YOUR_TOKEN"

curl -X POST \
  https://awx.example.com/api/v2/workflow_jobs/50/cancel/ \
  -H "Authorization: Bearer YOUR_TOKEN"

curl -X POST \
  https://awx.example.com/api/v2/workflow_jobs/50/relaunch/ \
  -H "Authorization: Bearer YOUR_TOKEN"

curl -X GET \
  https://awx.example.com/api/v2/workflow_jobs/50/labels/ \
  -H "Authorization: Bearer YOUR_TOKEN"

curl -X GET \
  https://awx.example.com/api/v2/workflow_jobs/50/notifications/ \
  -H "Authorization: Bearer YOUR_TOKEN"

curl -X GET \
  https://awx.example.com/api/v2/workflow_jobs/50/activity_stream/ \
  -H "Authorization: Bearer YOUR_TOKEN"

# By status
?status=successful

# By workflow template
?workflow_job_template=5

# By date range
?created__gte=2024-01-01

# By launch type
?launch_type=scheduled

import requests
import time

base_url = "https://awx.example.com/api/v2"
token = "YOUR_TOKEN"
headers = {"Authorization": f"Bearer {token}"}
workflow_job_id = 50

def get_workflow_status():
    response = requests.get(
        f"{base_url}/workflow_jobs/{workflow_job_id}/",
        headers=headers
    )
    return response.json()

def get_workflow_nodes():
    response = requests.get(
        f"{base_url}/workflow_jobs/{workflow_job_id}/workflow_nodes/",
        headers=headers
    )
    return response.json()['results']

# Monitor workflow
while True:
    workflow = get_workflow_status()
    status = workflow['status']
    
    print(f"Workflow status: {status}")
    
    # Get node statuses
    nodes = get_workflow_nodes()
    for node in nodes:
        node_status = "pending"
        if node.get('job'):
            node_status = "completed"
        if node.get('do_not_run'):
            node_status = "skipped"
        
        print(f"  Node {node['identifier']}: {node_status}")
    
    if status in ['successful', 'failed', 'error', 'canceled']:
        print(f"\nWorkflow finished: {status}")
        break
    
    time.sleep(5)