id: cascade_pipeline
namespace: company.data

triggers:
 - id: staging_table_event
   type: io.kestra.plugin.ee.assets.EventTrigger
   namespace: company.data
   assetType: io.kestra.plugin.ee.assets.Table
   events:
     - CREATED
     - UPDATED
   metadataQuery:
     - field: model_layer
       type: EQUAL_TO
       value: staging

tasks:
 - id: transform_to_mart
   type: io.kestra.plugin.core.flow.Subflow
   namespace: company.data
   flowId: create_mart_tables
   inputs:
     source_table: "{{ trigger.assets[0].id }}"

id: audit_deletions
namespace: company.security

triggers:
 - id: asset_deletion_monitor
   type: io.kestra.plugin.ee.assets.EventTrigger
   events:
     - DELETED

tasks:
 - id: log_deletion
   type: io.kestra.plugin.jdbc.postgresql.Query
   sql: |
     INSERT INTO audit_log (asset_id, asset_type, namespace, deleted_at, deleted_by)
     VALUES (
       '{{ trigger.assets[0].id }}',
       '{{ trigger.assets[0].type }}',
       '{{ trigger.assets[0].namespace }}',
       '{{ trigger.assets[0].eventTime }}',
       '{{ trigger.assets[0].tenantId }}'
     )

id: auto_configure_monitoring
namespace: company.infra

triggers:
  - id: new_vm_created
    type: io.kestra.plugin.ee.assets.EventTrigger
    assetType: io.kestra.plugin.ee.assets.VM
    events:
      - CREATED

tasks:
  - id: setup_monitoring
    type: io.kestra.plugin.scripts.shell.Commands
    commands:
      - |
        configure-monitoring \
          --vm-id {{ trigger.assets[0].id }} \
          --region {{ trigger.assets[0].metadata.region }} \
          --provider {{ trigger.assets[0].metadata.provider }}

id: team_notifications
 namespace: company.notifications

 triggers:
   - id: data_team_assets
     type: io.kestra.plugin.ee.assets.EventTrigger
     events:
       - UPDATED
     metadataQuery:
       - field: owner
         type: EQUAL_TO
         value: data-team

 tasks:
   - id: notify_slack
     type: io.kestra.plugin.notifications.slack.SlackIncoming
     url: "{{ secret('DATA_TEAM_WEBHOOK') }}"
     payload: |
       {
         "text": "📊 Asset `{{ trigger.assets[0].id }}` was updated"
       }

id: critical_asset_monitor
namespace: company.monitoring

triggers:
  - id: critical_assets
    type: io.kestra.plugin.ee.assets.EventTrigger
    events:
      - CREATED
      - UPDATED
    metadataQuery:
      - field: environment
        type: IS_ONE_OF
        value: [prod, staging]
      - field: priority
        type: EQUAL_TO
        value: critical
      - field: status
        type: NOT_EQUAL_TO
        value: archived
      - field: description
        type: CONTAINS
        value: production

tasks:
  - id: validate_asset
    type: io.kestra.plugin.core.log.Log
    message: "Critical asset {{ trigger.assets[0].id }} in {{ trigger.assets[0].metadata.environment }} requires validation"