pipeline "query_cloud_resources" {
  step "query" "steampipe" {
    connection = "postgres://localhost:9193"
    sql        = "select * from cloud"
  }
}

trigger "interval" "my_hourly_trigger" {
  trigger  = "hourly"
  pipeline = pipeline.my_job
}

pipeline "my_job" {
  step "http" "call_webhook" {
    url = "http://example.com/my/webhook"
  }
}

pipeline "notify" {
  step "pipeline" "astros" {
    pipeline = pipeline.get_astronauts
  }

  step "pipeline" "post_slack_message" {
    pipeline = slack.pipeline.post_message
    args = {
      token   = params.token
      channel = "astro_channel"
      message = "In space: ${step.pipeline.astros.output.people}"
    }
  }
}