Cancel
Showing results for 
Search instead for 
Did you mean: 
Highlighted

Sequence processor in Data Flow API

Experimenter
Experimenter

I'm trying to set up a stream that will use the sequence processor. I have set up the two streams I want to use to be directed to the SNS "jointStream". Currently when I try to deploy the stream it fails. Is it my syntax or? Also, the example code from developer.mindsphere.io doesn't seem to work either.

{
    "name": "JointStream",
    "definition": ":jointStream > Sequence --labels='[\"sensor\",\"timer\"]' --initial-conditions='{\"first\":\"sensor\",\"second\":\"timer\",\"within\":\"PT70S\"},{\"first\":\"timer\",\"second\":\"timer\",\"within\":\"PT70S\"}' --label-path=headers[\"title\"] | EmailSink --message-category-id=1234 --body='{}'",
    "deploy": true
}

EDIT:

Solved by assuming the initial conditions need to be enclosed with an array notation.
as in [{a:b},{b:c}]