diff --git a/kapacitor/pipeline_test.go b/kapacitor/pipeline_test.go index bb07a3cab5..a095a97d63 100644 --- a/kapacitor/pipeline_test.go +++ b/kapacitor/pipeline_test.go @@ -149,41 +149,41 @@ alert4 } func TestPipelineJSONDeadman(t *testing.T) { script := `var db = 'telegraf' - + var rp = 'autogen' - + var measurement = 'cpu' - + var groupBy = ['host', 'cluster_id'] - + var whereFilter = lambda: ("cpu" == 'cpu_total') AND ("host" == 'acc-0eabc309-eu-west-1-data-3' OR "host" == 'prod') - + var period = 10m - + var name = 'name' - + var idVar = name + ':{{.Group}}' - + var message = 'message' - + var idTag = 'alertID' - + var levelTag = 'level' - + var messageField = 'message' - + var durationField = 'duration' - + var outputDB = 'chronograf' - + var outputRP = 'autogen' - + var outputMeasurement = 'alerts' - + var triggerType = 'deadman' - + var threshold = 0.0 - + var data = stream |from() .database(db) @@ -191,7 +191,7 @@ func TestPipelineJSONDeadman(t *testing.T) { .measurement(measurement) .groupBy(groupBy) .where(whereFilter) - + var trigger = data |deadman(threshold, period) .stateChangesOnly() @@ -204,7 +204,7 @@ func TestPipelineJSONDeadman(t *testing.T) { .slack() .victorOps() .email() - + trigger |eval(lambda: "emitted") .as('value') @@ -216,7 +216,7 @@ func TestPipelineJSONDeadman(t *testing.T) { .measurement(outputMeasurement) .tag('alertName', name) .tag('triggerType', triggerType) - + trigger |httpOut('output') ` @@ -251,9 +251,6 @@ var alert5 = from1 .victorOps() .slack() -alert5 - |httpOut('output') - alert5 |eval(lambda: "emitted") .as('value') @@ -268,6 +265,9 @@ alert5 .create() .tag('alertName', 'name') .tag('triggerType', 'deadman') + +alert5 + |httpOut('output') ` octets, err := MarshalTICK(script)