StartStream | Kestra

StartStream

Start a streaming Slack message

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

Examples

yaml
id: slack_start_stream
namespace: company.team

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

yaml
id: slack_stream_thread
namespace: company.team

tasks:
  - id: post_message
    type: io.kestra.plugin.slack.app.chats.Post
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "#general"
    messageText: "Starting new process"

  - id: start_stream
    type: io.kestra.plugin.slack.app.chats.StartStream
    token: "{{ secret('SLACK_TOKEN') }}"
    channel: "#general"
    threadTs: "{{ outputs.post_message.timestamp }}"
    markdownText: "Process details streaming..."

yaml
id: slack_stream_workflow
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"

  - 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: "All steps completed!"