Skip to content

fix: health check waits for tasks to finish before becoming unhealthy #4596

fix: health check waits for tasks to finish before becoming unhealthy

fix: health check waits for tasks to finish before becoming unhealthy #4596

GitHub Actions / Test - windows Adaptors/Memory/tests succeeded Oct 31, 2024 in 0s

186 passed, 0 failed and 0 skipped

Tests passed successfully

✅ Adaptors/Memory/tests/TestResults/test-results.trx

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

Test suite Passed Failed Skipped Time
ArmoniK.Core.Adapters.Memory.Tests.ResultTableTests 27✅ 1s
ArmoniK.Core.Adapters.Memory.Tests.SessionTableTests 24✅ 88ms
ArmoniK.Core.Adapters.Memory.Tests.TaskTableTests 135✅ 451ms

✅ ArmoniK.Core.Adapters.Memory.Tests.ResultTableTests

✅ AbortResultsShouldFail
✅ AbortResultsShouldSucceed
✅ AddDependentNotExistingResultShouldThrow
✅ AddDependentShouldSucceed
✅ ChangeResultOwnershipShouldSucceed
✅ CompleteResultShouldSucceed
✅ CompleteResultShouldThrow
✅ CreateShouldFail
✅ CreateShouldSucceed
✅ DeleteResultShouldRemoveOne
✅ DeleteResultsShouldRemoveAll
✅ DeleteUnknownResultShouldFail
✅ GetDependentsShouldSucceed
✅ GetDependentsShouldThrow
✅ GetEmptyDependentsShouldSucceed
✅ GetNotExistingResultStatusShouldSucceed
✅ GetResultBench
✅ GetResultsBench
✅ GetResultStatusShouldSucceed
✅ InitShouldSucceed
✅ ListResultsAsyncFilterResultStatusAndSessionIdLimit1ShouldSucceed
✅ ListResultsAsyncFilterResultStatusAndSessionIdShouldSucceed
✅ ListSessionAsyncNoFilterShouldSucceed
✅ SetResultShouldSucceed
✅ SetResultSmallPayloadShouldSucceed
✅ SetTaskOwnershipShouldFail
✅ SetTaskOwnershipShouldSucceed

✅ ArmoniK.Core.Adapters.Memory.Tests.SessionTableTests

✅ CancelCancelledSessionAsyncShouldFail
✅ CancelDeletedSessionShouldThrow
✅ CancelPurgedSessionShouldThrow
✅ CancelSessionAsyncShouldFail
✅ CancelSessionAsyncShouldSucceed
✅ CloseClosedSessionShouldThrow
✅ DeleteSessionAsyncShouldNotThrow
✅ DeleteSessionAsyncShouldSucceed
✅ GetDefaultTaskOptionAsyncShouldFail
✅ GetDefaultTaskOptionAsyncShouldSucceed
✅ InitShouldSucceed
✅ IsSessionCancelledAsyncShouldFail
✅ IsSessionCancelledAsyncShouldSucceed
✅ ListSessionAsyncFilterApplicationNameAndSessionIdShouldSucceed
✅ ListSessionAsyncFilterApplicationNameAndStatusShouldSucceed
✅ ListSessionAsyncFilterApplicationNameShouldSucceed
✅ ListSessionAsyncNoFilterShouldSucceed
✅ ListSessionAsyncShouldFail
✅ ListSessionAsyncShouldSucceed
✅ ListSessionAsyncShouldSucceed2
✅ ListSessionAsyncTaskOptionsOptions
✅ SessionLifeCycle
✅ StopBothSubmissionShouldSucceed
✅ StopSubmissionShouldSucceed

✅ ArmoniK.Core.Adapters.Memory.Tests.TaskTableTests

✅ AcquireAcquiredTaskShouldReturnSame
✅ AcquireCreatingTaskShouldFail
✅ AcquireTaskShouldFail
✅ AcquireTaskShouldSucceed
✅ AcquireUnknownTaskShouldThrow
✅ CancelSessionAsyncShouldSucceed
✅ CancelTasksAsyncEmptyListShouldSucceed
✅ CancelTasksAsyncShouldNotChangeTheGivenStatus(Cancelled)
✅ CancelTasksAsyncShouldNotChangeTheGivenStatus(Cancelling)
✅ CancelTasksAsyncShouldNotChangeTheGivenStatus(Completed)
✅ CancelTasksAsyncShouldNotChangeTheGivenStatus(Error)
✅ CancelTasksShouldSucceed
✅ CountAllTasksAsyncShouldSucceed
✅ CountPartitionTasksAsyncShouldSucceed
✅ CountTasksAsyncShouldSucceed
✅ CreateSameTaskShouldThrow
✅ DeleteTaskFromSessionShouldSucceed
✅ DeleteTaskFromSessionTwiceShouldSucceed
✅ DeleteTaskShouldFail
✅ DeleteTaskShouldSucceed
✅ FinalizeTaskCreationShouldFail
✅ FinalizeTaskCreationShouldSucceed(False)
✅ FinalizeTaskCreationShouldSucceed(True)
✅ FindTasksAsyncContainsShouldSucceed
✅ FindTasksAsyncStatusShouldSucceed(Completed,1)
✅ FindTasksAsyncStatusShouldSucceed(Processing,2)
✅ GetExpectedOutputKeysShouldSucceed
✅ GetParentTaskIdsShouldFail
✅ GetParentTaskIdsShouldSucceed
✅ GetTaskOutputShouldFail
✅ GetTaskOutputShouldSucceed
✅ InitShouldSucceed
✅ ListApplicationFromTasksShouldSucceed
✅ ListApplicationFromTasksSortShouldSucceed
✅ ListTaskEmptyResultShouldSucceed
✅ ListTaskFilter({ "field": { "taskOptionField": { "field": "TASK_OPTION_ENUM_FIELD_MAX_RETRIES" } }, "filterNumber": { "value": "5", "operator": "FILTER_NUMBER_OPERATOR_LESS_THAN_OR_EQUAL" } } true)
✅ ListTaskFilter({ "field": { "taskOptionField": { "field": "TASK_OPTION_ENUM_FIELD_MAX_RETRIES" } }, "filterNumber": { "value": "5", "operator": "FILTER_NUMBER_OPERATOR_LESS_THAN" } } false)
✅ ListTaskFilter({ "field": { "taskOptionField": { "field": "TASK_OPTION_ENUM_FIELD_PARTITION_ID" } }, "filterString": { "value": "BadPartitionId" } } false)
✅ ListTaskFilter({ "field": { "taskOptionField": { "field": "TASK_OPTION_ENUM_FIELD_PARTITION_ID" } }, "filterString": { "value": "part1" } } true)
✅ ListTaskFilter({ "field": { "taskOptionGenericField": { "field": "key1" } }, "filterString": { "value": "val1" } } true)
✅ ListTaskFilter({ "field": { "taskOptionGenericField": { "field": "key1" } }, "filterString": { "value": "val1", "operator": "FILTER_STRING_OPERATOR_CONTAINS" } } true)
✅ ListTaskFilter({ "field": { "taskOptionGenericField": { "field": "key1" } }, "filterString": { "value": "val1", "operator": "FILTER_STRING_OPERATOR_ENDS_WITH" } } true)
✅ ListTaskFilter({ "field": { "taskOptionGenericField": { "field": "key1" } }, "filterString": { "value": "val1", "operator": "FILTER_STRING_OPERATOR_STARTS_WITH" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_CREATED_AT" } }, "filterDate": { "value": "2020-03-15T00:00:00Z", "operator": "FILTER_DATE_OPERATOR_AFTER_OR_EQUAL" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_CREATED_AT" } }, "filterDate": { "value": "2020-03-15T00:00:00Z", "operator": "FILTER_DATE_OPERATOR_AFTER" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_CREATED_AT" } }, "filterDate": { "value": "2020-03-15T00:00:00Z", "operator": "FILTER_DATE_OPERATOR_BEFORE_OR_EQUAL" } } false)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_CREATED_AT" } }, "filterDate": { "value": "2020-03-15T00:00:00Z", "operator": "FILTER_DATE_OPERATOR_BEFORE" } } false)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_CREATED_BY" } }, "filterString": { "value": "BadCreatedBy" } } false)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_CREATED_BY" } }, "filterString": { "value": "CreatedBy" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_FETCHED_AT" } }, "filterDate": { } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_PAYLOAD_ID" } }, "filterString": { "value": "BadPayloadId" } } false)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_PAYLOAD_ID" } }, "filterString": { "value": "PayloadId" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_PROCESSED_AT" } }, "filterDate": { } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_RECEIVED_TO_END_DURATION" } }, "filterDuration": { } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_SESSION_ID" } }, "filterString": { "value": "BadSessionId" } } false)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_SESSION_ID" } }, "filterString": { "value": "BadSessionId", "operator": "FILTER_STRING_OPERATOR_NOT_CONTAINS" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_SESSION_ID" } }, "filterString": { "value": "SessionId" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_SESSION_ID" } }, "filterString": { "value": "SessionId", "operator": "FILTER_STRING_OPERATOR_CONTAINS" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_SESSION_ID" } }, "filterString": { "value": "SessionId", "operator": "FILTER_STRING_OPERATOR_ENDS_WITH" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_SESSION_ID" } }, "filterString": { "value": "SessionId", "operator": "FILTER_STRING_OPERATOR_STARTS_WITH" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_STARTED_AT" } }, "filterDate": { } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_STARTED_AT" } }, "filterDate": { } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_STATUS" } }, "filterStatus": { "value": "TASK_STATUS_CANCELLING" } } false)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_STATUS" } }, "filterStatus": { "value": "TASK_STATUS_CANCELLING", "operator": "FILTER_STATUS_OPERATOR_NOT_EQUAL" } } true)
✅ ListTaskFilter({ "field": { "taskSummaryField": { "field": "TASK_SUMMARY_ENUM_FIELD_STATUS" } }, "filterStatus": { "value": "TASK_STATUS_COMPLETED" } } true)
✅ ListTaskShouldSucceed
✅ ListTaskWithIndividualMaskShouldSucceed(AcquisitionDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(CreatedBy,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(CreationDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(CreationToEndDuration,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(DataDependencies,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(DataDependenciesCount,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(EndDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ExpectedOutputIds,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ExpectedOutputIdsCount,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(FetchedDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(InitialTaskId,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[ApplicationNamespace, ApplicationService])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[ApplicationNamespace])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[ApplicationService])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[ApplicationVersion])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[EngineType])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[MaxDuration])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[MaxRetries])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[Options])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[PartitionId])
✅ ListTaskWithIndividualMaskShouldSucceed(Options,[Priority])
✅ ListTaskWithIndividualMaskShouldSucceed(Output,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(OwnerPodId,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(OwnerPodName,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ParentTaskIds,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ParentTaskIdsCount,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(PayloadId,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(PodTtl,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ProcessedDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ProcessingToEndDuration,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ReceivedToEndDuration,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(ReceptionDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(RetryOfIds,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(RetryOfIdsCount,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(SessionId,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(StartDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(Status,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(StatusMessage,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(SubmittedDate,[ApplicationName])
✅ ListTaskWithIndividualMaskShouldSucceed(TaskId,[ApplicationName])
✅ ListTaskWithListInRequestShouldSucceed
✅ ListTaskWithMaskShouldSucceed
✅ ListTaskWithRequestOrderByTaskOptionsOptionsShouldSucceed
✅ ListTaskWithRequestShouldSucceed
✅ OptionsAreEqual
✅ PayloadIdAfterRetryShouldBeCorrect
✅ ReadTaskAsyncShouldFail
✅ ReadTaskAsyncShouldSucceed
✅ ReleaseTaskShouldSucceed
✅ RemoveRemainingDataDependenciesDepDoesNotExistShouldSucceed
✅ RemoveRemainingDataDependenciesShouldSucceed
✅ RetryTaskShouldSucceed
✅ SetTaskCanceledAsyncShouldSucceed
✅ SetTaskErrorAsyncShouldSucceed
✅ SetTaskSuccessAsyncShouldSucceed
✅ StartTaskInFinalStateShouldThrow(Cancelled)
✅ StartTaskInFinalStateShouldThrow(Completed)
✅ StartTaskInFinalStateShouldThrow(Error)
✅ StartTaskInFinalStateShouldThrow(Retried)
✅ StartTaskShouldFail
✅ StartTaskShouldSucceed
✅ UpdateAllTaskStatusAsyncShouldFailOnSomeStatus(Cancelled)
✅ UpdateAllTaskStatusAsyncShouldFailOnSomeStatus(Completed)
✅ UpdateAllTaskStatusAsyncShouldFailOnSomeStatus(Error)
✅ UpdateAllTaskStatusAsyncShouldSucceed
✅ UpdateAllTaskStatusAsyncShouldSucceedIfNoStatusGiven