id: update_task_status
namespace: company.airtable

tasks:
  - id: update_task
    type: io.kestra.plugin.airtable.records.Update
    baseId: "{{ secret('AIRTABLE_BASE_ID') }}"
    tableId: "Tasks"
    recordId: "recXXXXXXXXXXXXXX"
    apiKey: "{{ secret('AIRTABLE_PERSONAL_ACCESS_TOKEN') }}"
    fields:
      "Status": "In Progress"
      "Progress": 50
      "Last Updated": "{{ now() }}"
    typecast: true

id: update_customer
namespace: company.airtable

tasks:
  - id: update_customer_info
    type: io.kestra.plugin.airtable.records.Update
    baseId: "{{ secret('AIRTABLE_BASE_ID') }}"
    tableId: "Customers"
    recordId: "{{ inputs.customer_record_id }}"
    apiKey: "{{ secret('AIRTABLE_PERSONAL_ACCESS_TOKEN') }}"
    fields:
      "Email": "{{ inputs.new_email }}"
      "Phone": "{{ inputs.new_phone }}"
      "Last Contact": "{{ now() | date('yyyy-MM-dd') }}"

id: conditional_update
namespace: company.airtable

tasks:
  - id: update_conditionally
    type: io.kestra.plugin.airtable.records.Update
    baseId: "{{ secret('AIRTABLE_BASE_ID') }}"
    tableId: "Orders"
    recordId: "{{ inputs.order_id }}"
    apiKey: "{{ secret('AIRTABLE_PERSONAL_ACCESS_TOKEN') }}"
    fields:
      "Status": "{{ inputs.status }}"
      "Completed Date": "{{ inputs.status == 'Completed' ? now() : null }}"
      "Notes": "Updated via Kestra workflow"