AppendStream | Kestra

AppendStream

Append to a Slack stream

yaml
type: "io.kestra.plugin.slack.app.chats.AppendStream"

Examples

yaml
id: slack_append_stream
namespace: company.team

tasks:
  - id: start_stream
    type: io.kestra.plugin.slack.app.chats.StartStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "#general"
    markdownText: "Processing workflow..."

  - id: append_stream
    type: io.kestra.plugin.slack.app.chats.AppendStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "{{ outputs.start_stream.channel }}"
    timestamp: "{{ outputs.start_stream.timestamp }}"
    markdownText: "Step 1 completed successfully"

yaml
id: slack_multi_append_stream
namespace: company.team

tasks:
  - id: start_stream
    type: io.kestra.plugin.slack.app.chats.StartStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "#general"
    markdownText: "Starting data processing..."

  - id: append_step1
    type: io.kestra.plugin.slack.app.chats.AppendStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "{{ outputs.start_stream.channel }}"
    timestamp: "{{ outputs.start_stream.timestamp }}"
    markdownText: "\\nFetching data from source..."

  - id: append_step2
    type: io.kestra.plugin.slack.app.chats.AppendStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "{{ outputs.start_stream.channel }}"
    timestamp: "{{ outputs.start_stream.timestamp }}"
    markdownText: "\\nProcessing 1000 records..."

  - id: stop_stream
    type: io.kestra.plugin.slack.app.chats.StopStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "{{ outputs.start_stream.channel }}"
    timestamp: "{{ outputs.start_stream.timestamp }}"
    markdownText: "\\n✅ Processing complete!"

yaml
id: slack_stream_progress
namespace: company.team

tasks:
  - id: start_stream
    type: io.kestra.plugin.slack.app.chats.StartStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "#general"
    markdownText: "Starting long-running process..."

  - id: update_progress
    type: io.kestra.plugin.slack.app.chats.AppendStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "{{ outputs.start_stream.channel }}"
    timestamp: "{{ outputs.start_stream.timestamp }}"
    markdownText: "\\nProgress: {{ taskrun.value }}%"