Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[NU-1979] Scenario statuses refactor: scenario status and deployment statuses are decoupled #7566

Merged
merged 25 commits into from
Feb 25, 2025

typo fix

144fbf6
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

[NU-1979] Scenario statuses refactor: scenario status and deployment statuses are decoupled #7566

typo fix
144fbf6
Select commit
Loading
Failed to load commit list.
GitHub Actions / REPORT-IntegrationTests-2.13 succeeded Feb 21, 2025 in 0s

55 passed, 0 failed and 2 skipped

Tests passed successfully

Report Passed Failed Skipped Time
components/openapi/target/it-reports/TEST-pl.touk.nussknacker.openapi.functional.OpenApiScenarioIntegrationTest.xml 4✅ 29s
components/openapi/target/it-reports/TEST-pl.touk.nussknacker.openapi.functional.OpenAPIServiceSpec.xml 1✅ 6s
designer/processReports/target/it-reports/TEST-pl.touk.nussknacker.processCounts.influxdb.InfluxCountsReporterSpec.xml 3✅ 4s
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerScenarioTestingSpec.xml 2✅ 22s
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerSlotsCountSpec.xml 1✅ 2s
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.JavaConfigDeploymentManagerSpec.xml 1✅ 19s
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.MiniClusterFlinkDeploymentManagerSpec.xml 11✅ 1⚪ 56s
engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.RemoteFlinkDeploymentManagerSpec.xml 11✅ 1⚪ 154s
engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeBinTest.xml 1✅ 9s
engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerAvroTest.xml 1✅ 30s
engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerJsonTest.xml 1✅ 31s
engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerProbesTest.xml 2✅ 63s
engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeBinTest.xml 1✅ 7s
engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeDockerTest.xml 2✅ 391ms
security/target/it-reports/TEST-pl.touk.nussknacker.ui.security.oauth2.GenericOidcServiceSpec.xml 1✅ 6s
utils/kafka-components-utils/target/it-reports/TEST-pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateDisabledTest.xml 6✅ 2s
utils/kafka-components-utils/target/it-reports/TEST-pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateEnabledTest.xml 6✅ 4s

✅ components/openapi/target/it-reports/TEST-pl.touk.nussknacker.openapi.functional.OpenApiScenarioIntegrationTest.xml

4 tests were completed in 29s with 4 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.openapi.functional.OpenApiScenarioIntegrationTest 4✅ 29s

✅ pl.touk.nussknacker.openapi.functional.OpenApiScenarioIntegrationTest

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

✅ components/openapi/target/it-reports/TEST-pl.touk.nussknacker.openapi.functional.OpenAPIServiceSpec.xml

1 tests were completed in 6s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.openapi.functional.OpenAPIServiceSpec 1✅ 6s

✅ pl.touk.nussknacker.openapi.functional.OpenAPIServiceSpec

✅ service returns customers

✅ designer/processReports/target/it-reports/TEST-pl.touk.nussknacker.processCounts.influxdb.InfluxCountsReporterSpec.xml

3 tests were completed in 4s with 3 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.processCounts.influxdb.InfluxCountsReporterSpec 3✅ 4s

✅ pl.touk.nussknacker.processCounts.influxdb.InfluxCountsReporterSpec

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

✅ engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerScenarioTestingSpec.xml

2 tests were completed in 22s with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerScenarioTestingSpec 2✅ 22s

✅ pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerScenarioTestingSpec

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

✅ engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerSlotsCountSpec.xml

1 tests were completed in 2s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerSlotsCountSpec 1✅ 2s

✅ pl.touk.nussknacker.engine.management.streaming.FlinkDeploymentManagerSlotsCountSpec

✅ deploy scenario with too low task manager slots counts

✅ engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.JavaConfigDeploymentManagerSpec.xml

1 tests were completed in 19s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.management.streaming.JavaConfigDeploymentManagerSpec 1✅ 19s

✅ pl.touk.nussknacker.engine.management.streaming.JavaConfigDeploymentManagerSpec

✅ deploy java scenario in running flink

✅ engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.MiniClusterFlinkDeploymentManagerSpec.xml

12 tests were completed in 56s with 11 passed, 0 failed and 1 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.management.streaming.MiniClusterFlinkDeploymentManagerSpec 11✅ 1⚪ 56s

✅ pl.touk.nussknacker.engine.management.streaming.MiniClusterFlinkDeploymentManagerSpec

✅ 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

✅ engine/flink/management/target/it-reports/TEST-pl.touk.nussknacker.engine.management.streaming.RemoteFlinkDeploymentManagerSpec.xml

12 tests were completed in 154s with 11 passed, 0 failed and 1 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.management.streaming.RemoteFlinkDeploymentManagerSpec 11✅ 1⚪ 154s

✅ pl.touk.nussknacker.engine.management.streaming.RemoteFlinkDeploymentManagerSpec

✅ 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

✅ engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeBinTest.xml

1 tests were completed in 9s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeBinTest 1✅ 9s

✅ pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeBinTest

✅ should run scenario and pass data to output

✅ engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerAvroTest.xml

1 tests were completed in 30s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerAvroTest 1✅ 30s

✅ pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerAvroTest

✅ avro ping-pong should work

✅ engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerJsonTest.xml

1 tests were completed in 31s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerJsonTest 1✅ 31s

✅ pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerJsonTest

✅ json ping-pong should work

✅ engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerProbesTest.xml

2 tests were completed in 63s with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerProbesTest 2✅ 63s

✅ pl.touk.nussknacker.engine.lite.kafka.NuKafkaRuntimeDockerProbesTest

✅ readiness probe
✅ liveness probe

✅ engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeBinTest.xml

1 tests were completed in 7s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeBinTest 1✅ 7s

✅ pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeBinTest

✅ binary version should handle ping pong via http

✅ engine/lite/integration-test/target/it-reports/TEST-pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeDockerTest.xml

2 tests were completed in 391ms with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeDockerTest 2✅ 391ms

✅ pl.touk.nussknacker.engine.lite.requestresponse.NuReqRespRuntimeDockerTest

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

✅ security/target/it-reports/TEST-pl.touk.nussknacker.ui.security.oauth2.GenericOidcServiceSpec.xml

1 tests were completed in 6s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.ui.security.oauth2.GenericOidcServiceSpec 1✅ 6s

✅ pl.touk.nussknacker.ui.security.oauth2.GenericOidcServiceSpec

✅ Basic OpenIDConnect flow

✅ utils/kafka-components-utils/target/it-reports/TEST-pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateDisabledTest.xml

6 tests were completed in 2s with 6 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateDisabledTest 6✅ 2s

✅ pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateDisabledTest

✅ 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

✅ utils/kafka-components-utils/target/it-reports/TEST-pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateEnabledTest.xml

6 tests were completed in 4s with 6 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateEnabledTest 6✅ 4s

✅ pl.touk.nussknacker.engine.kafka.validator.CachedTopicsExistenceValidatorWhenAutoCreateEnabledTest

✅ 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