✅ should should enrich scenario with data
✅ should call enricher with primitive request body
✅ should call enricher with request body
✅ should call enricher returning string

✅ service returns customers

✅ invokes counts for point in time data
✅ invokes query for date range
✅ should detect restarts one SingleDifference mode

✅ should run scenario in test mode
✅ should return correct error messages

✅ deploy scenario with too low task manager slots counts

✅ deploy java scenario in running flink

✅ deploy scenario in running flink
✅ use deploymentId passed as a jobId
⚪ continue on timeout exception during scenario deploy
✅ cancel of not existing job should not fail
✅ be able verify&redeploy kafka scenario
✅ save state when redeploying
✅ redeploy scenario with greater parallelism than configured in mini cluster
✅ snapshot state and be able to deploy using it
✅ should stop scenario and deploy it using savepoint
✅ fail to redeploy if old is incompatible
✅ fail to redeploy if result produced by aggregation is incompatible
✅ extract scenario definition

✅ deploy scenario in running flink
✅ use deploymentId passed as a jobId
⚪ continue on timeout exception during scenario deploy
✅ cancel of not existing job should not fail
✅ be able verify&redeploy kafka scenario
✅ save state when redeploying
✅ redeploy scenario with greater parallelism than configured in mini cluster
✅ snapshot state and be able to deploy using it
✅ should stop scenario and deploy it using savepoint
✅ fail to redeploy if old is incompatible
✅ fail to redeploy if result produced by aggregation is incompatible
✅ extract scenario definition

✅ should run scenario and pass data to output

✅ avro ping-pong should work

✅ json ping-pong should work

✅ readiness probe
✅ liveness probe

✅ binary version should handle ping pong via http

✅ docker image should handle ping pong via http
✅ should get scenario definition via http

✅ Basic OpenIDConnect flow

✅ should validate existing source topic
✅ should validate not existing source topic
✅ should validate existing sink topic
✅ should validate not existing sink topic
✅ should not validate not existing topic when validation disabled
✅ should fetch topics every time when not valid using cache

✅ should validate existing source topic
✅ should not validate not existing source topic
✅ should validate existing sink topic
✅ should validate not existing sink topic
✅ should not validate not existing topic when validation disabled
✅ should use cache when validating