but when I call

startPipelineExecution

the graphql websocket never emits a

type:stop

command so the call to client.mutate hangs - I assume this is where the subscription stuff needs to be put in right?