All files / src/graphql pipeline.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
 
 
2x
 
 
 
 
 
 
2x
 
 
 
 
 
 
 
 
 
import { gql } from '@apollo/client';
 
/* Subscription that streams generic JSON payloads – one per push */
export const DATA_PIPELINE_STREAM_SUB = gql`
  subscription ($channel: String!) {
    pubsub(channel: $channel)
  }
`;
 
/* Ordinary query that *starts* the job (kept for back-compat) */
export const TRIGGER_DATA_PIPELINE_QUERY = gql`
  query ($progressChannel: String!) {
    dataPipeline(progressChannel: $progressChannel) {
      name
      last_activity_at
      pipeline_status
    }
  }
`;