Simplify conditional branching for Microservice Orchestration about kestra HOT 1 OPEN

id: ecommerce-order-processing
namespace: ecommerce
description: E-commerce Order Processing Workflow

inputs:
  - id: orderId
    type: STRING

tasks:
  - id: checkInventory
    type: io.kestra.plugin.fs.http.Request
    description: Check inventory for the order items
    uri: http://inventory-service/check
    contentType: multipart/form-data
    formData:
      orderId: "{{ inputs.orderId }}"

  - id: processPayment
    type: io.kestra.plugin.fs.http.Request
    description: Process payment for the order
    uri: http://payment-service/process
    formData:
      orderId: "{{ inputs.ordered }}"    
    checks: 
      - type: BEFORE
        description: Check stock before accepting payment
        condition: "{{ outputs.checkInventory.body.inventoryAvailable == true }}"
        onConditionFail:
          - type: RUN_SUBFLOW
            flowId: alerting_flow_id
            namespace: myteam
          - type: SET_TASK_RUN_STATE
            state: WARNING # FAILED, WARNING, CANCELLED, KILLED

      - type: AFTER
        description: Validate payment result
        condition: "{{ outputs.processPayment.body.paymentResult == true }}"
        onConditionFail: # optional, by default failed condition leads to failing the taskrun
          - type: SET_TASK_RUN_STATE
            state: CANCELLED # FAILED, WARNING, CANCELLED, KILLED
    
  - id: orderConfirmation
    type: io.kestra.plugin.fs.http.Request
    description: Confirm the order and notify the customer
    uri: http://order-service/confirm
    formData:
      orderId: "{{ inputs.orderId }}"

  - id: arrangeShipping
    type: io.kestra.plugin.fs.http.Request
    description: Arrange shipping for the order
    uri: http://shipping-service/arrange
    formData:
      orderId: "{{ inputs.orderId }}"
    checks:
      - type: BEFORE
        condition: "{{ outputs.orderConfirmation.body.status == 'SUCCESS' }}"
        description: Check stock before accepting payment        
      - type: AFTER
        condition: "{{ outputs.arrangeShipping.body.status == 'SUCCESS' }}"

  - id: updateDeliveryStatus
    type: io.kestra.plugin.fs.http.Request
    description: Update the delivery status of the order
    uri: http://delivery-service/updateStatus
    formData:
      orderId: "{{ inputs.orderId }}"

taskDefaults:
  - type: io.kestra.plugin.fs.http.Request
    values:
      contentType: multipart/form-data
      method: POST