airflow.yaml

openapi: 3.0.0
info:
  version: 1.0.0
  title: Airflow events
  description: 'This file is used to hold schema definition, please refer to asyncapi.yaml for service description'
paths: {}
components:
  schemas:
    Audit:
      type: object
      properties:
        event_type:
          type: string
        uid:
          type: string
        dttm:
          type: string
          format: date-time
        timestamp:
          type: string
          description: timestamp of the generation of the event in Airflow
          format: date-time
        dag_id:
          type: string
          description: DAG identifier
        task_id:
          type: string
          description: Task identifier
        execution_date:
          type: string
          format: date-time
        action:
          type: string
          description: User action type in the UI
        user:
          type: string
          description: Logged in user identifier
      required:
        - uid
        - timestamp
        - action
        - user
        - event_type
    TaskState:
      type: object
      required:
        - timestamp
        - dag_id
        - task_id
        - execution_date
        - uid
        - event_type
      properties:
        event_type:
          type: string
        uid:
          type: string
        timestamp:
          type: string
          description: timestamp of the generation of the event in Airflow
          format: date-time
        dttm:
          type: string
        dag_id:
          type: string
          description: DAG identifier
        task_id:
          type: string
          description: Task identifier
        execution_date:
          type: string
          format: date-time
        state:
          type: string
          description: State of the Task
        state_before:
          type: string
          description: Previous state of the Task right before this event
        operator:
          type: string
          description: Airflow Operator name used for this Task
    DagState:
      type: object
      properties:
        event_type:
          type: string
        uid:
          type: string
        timestamp:
          type: string
          description: timestamp of the generation of the event in Airflow
          format: date-time
        dag_id:
          type: string
        execution_date:
          type: string
          format: date-time
        state:
          type: string
        state_before:
          type: string
        start_date:
          type: string
          format: date-time
        end_date:
          type: string
          format: date-time
        run_id:
          type: string
    DatabricksJobState:
      type: object
      properties:
        event_type:
          type: string
        uid:
          type: string
        timestamp:
          type: string
          description: timestamp of the generation of the event in Airflow
          format: date-time
        dttm:
          type: string
        dag_id:
          type: string
          description: DAG identifier
        task_id:
          type: string
          description: Task identifier
        execution_date:
          type: string
          format: date-time
        state:
          type: string
          description: State of the Task
        state_before:
          type: string
          description: Previous state of the Task right before this event
        operator:
          type: string
        run_id:
          type: integer
        run_url:
          type: string
      required:
        - uid
        - timestamp
        - dag_id
        - task_id
        - execution_date
        - event_type