ArmoniK.Core

Contents:

  • 1. ArmoniK.Core
  • 2. Local Deployment of ArmoniK.Core
  • 3. Tests in ArmoniK.Core
  • 4. How to execute tests in ArmoniK.Core?
  • 5. ArmoniK.Core performance tests with HtcMock
  • 6. How to migrate ArmoniK.Core dependencies during upgrade ?
  • 7. Create a Windows Virtual Machine on AWS to Deploy ArmoniK Core
  • 8. Install on Windows 11
  • 9. Project components
  • 10. Initialization
  • 11. Agent cache
  • 12. Tasks
  • 13. Authentication and Authorization
  • 14. Adaptors
  • 15. RabbitMQ Limitations
  • 16. MongoDB client connection problem
  • 17. Using external plugins with ArmoniK.Core
  • 18. TLS Implementation in the ArmoniK Core
  • 19. Partitions
  • 20. Artemis
  • 21. How to use ArmoniK RPCs
  • 22. Tasks Service RPCs actions
  • 23. Results Service RPCs actions
  • 24. Sessions Service RPCs actions
  • 25. Environment variables
  • 26. API reference
    • 26.1. Namespace ArmoniK
    • 26.2. Namespace ArmoniK.Core
    • 26.3. Namespace ArmoniK.Core.Adapters
    • 26.4. Namespace ArmoniK.Core.Adapters.Amqp
    • 26.5. Class ConnectionAmqp
    • 26.6. Interface IConnectionAmqp
    • 26.7. Class PullQueueStorage
    • 26.8. Class PushQueueStorage
    • 26.9. Class QueueBuilder
    • 26.10. Class QueueMessageHandler
    • 26.11. Class QueueStorage
    • 26.12. Namespace ArmoniK.Core.Adapters.Embed
    • 26.13. Class ObjectBuilder
    • 26.14. Class ObjectStorage
    • 26.15. Namespace ArmoniK.Core.Adapters.Gcs
    • 26.16. Class ObjectBuilder
    • 26.17. Class ObjectStorage
    • 26.18. Namespace ArmoniK.Core.Adapters.Gcs.Options
    • 26.19. Class Gcs
    • 26.20. Namespace ArmoniK.Core.Adapters.LocalStorage
    • 26.21. Class ObjectBuilder
    • 26.22. Class ObjectStorage
    • 26.23. Namespace ArmoniK.Core.Adapters.Memory
    • 26.24. Class ObjectStorage
    • 26.25. Class PushQueueStorage
    • 26.26. Class QueueStorage
    • 26.27. Class ResultTable
    • 26.28. Class ServiceCollectionExt
    • 26.29. Class SessionTable
    • 26.30. Class TaskTable
    • 26.31. Namespace ArmoniK.Core.Adapters.MongoDB
    • 26.32. Class AuthenticationTable
    • 26.33. Class ChangeStreamUpdate
    • 26.34. Namespace ArmoniK.Core.Adapters.MongoDB.Common
    • 26.35. Class BaseTable<TData, TModelMapping>
    • 26.36. Interface IMongoDataModelMapping<T>
    • 26.37. Class MongoCollectionProvider<TData, TModelMapping>
    • 26.38. Class SessionProvider
    • 26.39. Namespace ArmoniK.Core.Adapters.MongoDB.Options
    • 26.40. Class MongoDB
    • 26.41. Class TableStorage
    • 26.42. Class PartitionTable
    • 26.43. Class ResultTable
    • 26.44. Class ResultWatcher
    • 26.45. Class ServiceCollectionExt
    • 26.46. Class SessionTable
    • 26.47. Namespace ArmoniK.Core.Adapters.MongoDB.Table
    • 26.48. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
    • 26.49. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
    • 26.50. Class AuthDataAfterLookup
    • 26.51. Class AuthDataModelMapping
    • 26.52. Class MongoAuthResult
    • 26.53. Class RoleDataModelMapping
    • 26.54. Class UserDataAfterLookup
    • 26.55. Class UserDataModelMapping
    • 26.56. Class IndexHelper
    • 26.57. Class PartitionDataModelMapping
    • 26.58. Class ResultDataModelMapping
    • 26.59. Class SessionDataModelMapping
    • 26.60. Class ShardingExt
    • 26.61. Class TaskDataModelMapping
    • 26.62. Class TaskTable
    • 26.63. Class TaskWatcher
    • 26.64. Class WatchEnumerable<TOutput, TInput>
    • 26.65. Class WatchEnumerator<TOutput, TInput>
    • 26.66. Namespace ArmoniK.Core.Adapters.Nats
    • 26.67. Class Heart
    • 26.68. Class QueueBuilder
    • 26.69. Namespace ArmoniK.Core.Adapters.NullStorage
    • 26.70. Class ObjectBuilder
    • 26.71. Class ObjectStorage
    • 26.72. Namespace ArmoniK.Core.Adapters.PubSub
    • 26.73. Class Heart
    • 26.74. Class QueueBuilder
    • 26.75. Namespace ArmoniK.Core.Adapters.QueueCommon
    • 26.76. Class Amqp
    • 26.77. Class QueueStorageBase
    • 26.78. Namespace ArmoniK.Core.Adapters.Redis
    • 26.79. Class ObjectBuilder
    • 26.80. Class ObjectStorage
    • 26.81. Namespace ArmoniK.Core.Adapters.Redis.Options
    • 26.82. Class Redis
    • 26.83. Namespace ArmoniK.Core.Adapters.S3
    • 26.84. Class ObjectBuilder
    • 26.85. Class ObjectStorage
    • 26.86. Namespace ArmoniK.Core.Adapters.S3.Options
    • 26.87. Class S3
    • 26.88. Namespace ArmoniK.Core.Adapters.SQS
    • 26.89. Class Heart
    • 26.90. Class QueueBuilder
    • 26.91. Namespace ArmoniK.Core.Base
    • 26.92. Namespace ArmoniK.Core.Base.DataStructures
    • 26.93. Enum HealthCheckTag
    • 26.94. Class MessageData
    • 26.95. Class ObjectData
    • 26.96. Class TaskOptions
    • 26.97. Namespace ArmoniK.Core.Base.Exceptions
    • 26.98. Class ArmoniKException
    • 26.99. Class ObjectDataNotFoundException
    • 26.100. Class QueueInsertionFailedException
    • 26.101. Interface IDependencyInjectionBuildable
    • 26.102. Interface IHealthCheckProvider
    • 26.103. Interface IInitializable
    • 26.104. Interface IObjectStorage
    • 26.105. Interface IPullQueueStorage
    • 26.106. Interface IPushQueueStorage
    • 26.107. Interface IQueueMessageHandler
    • 26.108. Interface IQueueStorage
    • 26.109. Enum QueueMessageStatus
    • 26.110. Namespace ArmoniK.Core.Common
    • 26.111. Namespace ArmoniK.Core.Common.Auth
    • 26.112. Namespace ArmoniK.Core.Common.Auth.Authentication
    • 26.113. Class AuthData
    • 26.114. Class AuthenticationCache
    • 26.115. Class AuthenticationCacheKey
    • 26.116. Class Authenticator
    • 26.117. Class AuthenticatorOptions
    • 26.118. Interface IAuthenticationTable
    • 26.119. Class RoleData
    • 26.120. Class UserAuthenticationResult
    • 26.121. Class UserData
    • 26.122. Class UserIdentity
    • 26.123. Namespace ArmoniK.Core.Common.Auth.Authorization
    • 26.124. Class AuthorizationPolicyProvider
    • 26.125. Class GeneralService
    • 26.126. Class IgnoreAuthenticationAttribute
    • 26.127. Class IgnoreAuthorizationAttribute
    • 26.128. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
    • 26.129. Class Permission
    • 26.130. Class PermissionScope
    • 26.131. Class ServicesPermissions
    • 26.132. Class RequiresPermissionAttribute
    • 26.133. Namespace ArmoniK.Core.Common.Client
    • 26.134. Class GrpcChannelExt
    • 26.135. Class SessionStats
    • 26.136. Namespace ArmoniK.Core.Common.DynamicLoading
    • 26.137. Class CollocatedAssemblyResolver
    • 26.138. Namespace ArmoniK.Core.Common.Exceptions
    • 26.139. Class InvalidSessionTransitionException
    • 26.140. Class PartitionNotFoundException
    • 26.141. Class ResultNotFoundException
    • 26.142. Class SessionNotFoundException
    • 26.143. Class SubmissionClosedException
    • 26.144. Class TaskAlreadyExistsException
    • 26.145. Class TaskAlreadyInFinalStateException
    • 26.146. Class TaskCanceledException
    • 26.147. Class TaskNotFoundException
    • 26.148. Class TaskPausedException
    • 26.149. Class TimeoutException
    • 26.150. Class WorkerDownException
    • 26.151. Class HealthCheckRecord
    • 26.152. Class HealthCheckRecord.Publisher
    • 26.153. Interface IAsyncInitialization<T>
    • 26.154. Namespace ArmoniK.Core.Common.Injection
    • 26.155. Namespace ArmoniK.Core.Common.Injection.Options
    • 26.156. Class AdapterSettings
    • 26.157. Class Components
    • 26.158. Namespace ArmoniK.Core.Common.Injection.Options.Database
    • 26.159. Class Authentication
    • 26.160. Class Certificate
    • 26.161. Class InitDatabase
    • 26.162. Class Partition
    • 26.163. Class Partitioning
    • 26.164. Class Role
    • 26.165. Class User
    • 26.166. Class InitServices
    • 26.167. Class InitWorker
    • 26.168. Class Pollster
    • 26.169. Class Submitter
    • 26.170. Class ServiceCollectionExt
    • 26.171. Namespace ArmoniK.Core.Common.Meter
    • 26.172. Class FunctionExecutionMetrics<TIns>
    • 26.173. Class MeterHolder
    • 26.174. Namespace ArmoniK.Core.Common.Pollster
    • 26.175. Enum AcquisitionStatus
    • 26.176. Class Agent
    • 26.177. Class AgentHandler
    • 26.178. Class AgentIdentifier
    • 26.179. Class DataPrefetcher
    • 26.180. Interface IAgent
    • 26.181. Interface IAgentHandler
    • 26.182. Class Pollster
    • 26.183. Class PostProcessingTaskQueue
      • 26.183.1. Inheritance
      • 26.183.2. Inherited Members
    • 26.184. Class PostProcessor
    • 26.185. Class RunningTaskProcessor
    • 26.186. Class RunningTaskQueue
    • 26.187. Class TaskHandler
    • 26.188. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
    • 26.189. Interface ITaskProcessingChecker
    • 26.190. Class TaskProcessingCheckerClient
    • 26.191. Class TaskQueueBase
    • 26.192. Namespace ArmoniK.Core.Common.StateMachines
    • 26.193. Class ProcessReplyCreateLargeTaskStateMachine
    • 26.194. Enum ProcessReplyCreateLargeTaskStateMachine.State
    • 26.195. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
    • 26.196. Namespace ArmoniK.Core.Common.Storage
    • 26.197. Class Application
    • 26.198. Namespace ArmoniK.Core.Common.Storage.Events
    • 26.199. Interface IResultWatcher
    • 26.200. Interface ITaskWatcher
    • 26.201. Class NewResult
    • 26.202. Class NewTask
    • 26.203. Class ResultOwnerUpdate
    • 26.204. Class ResultStatusUpdate
    • 26.205. Class TaskStatusUpdate
    • 26.206. Interface IPartitionTable
    • 26.207. Interface IResultTable
    • 26.208. Class IResultTable.ChangeResultOwnershipRequest
    • 26.209. Interface ISessionTable
    • 26.210. Interface ITaskTable
    • 26.211. Class MaskedProjection
    • 26.212. Class Output
    • 26.213. Enum OutputStatus
    • 26.214. Class PartitionData
    • 26.215. Class PartitionTaskStatusCount
    • 26.216. Class PodConfiguration
    • 26.217. Class QueueMessageHandlerExt
    • 26.218. Class Result
    • 26.219. Class ResultCreationRequest
    • 26.220. Class ResultIdStatus
    • 26.221. Class ResultLifeCycleHelper
    • 26.222. Enum ResultStatus
    • 26.223. Class ResultTableExtensions
    • 26.224. Class SessionData
    • 26.225. Class SessionLifeCycleHelper
    • 26.226. Enum SessionStatus
    • 26.227. Class SessionTableExtensions
    • 26.228. Class TaskCreationRequest
    • 26.229. Class TaskData
    • 26.230. Enum TaskDataFields
    • 26.231. Class TaskDataHolder
    • 26.232. Class TaskDataMask
    • 26.233. Class TaskIdStatus
    • 26.234. Class TaskInfo
    • 26.235. Class TaskLifeCycleHelper
    • 26.236. Enum TaskOptionsFields
    • 26.237. Class TaskOptionsHolder
    • 26.238. Enum TaskStatus
    • 26.239. Class TaskStatusCount
    • 26.240. Class TaskSubmissionRequest
    • 26.241. Class TaskTableExtensions
    • 26.242. Class UpdateDefinition<T>
    • 26.243. Class UpdateDefinition<T>.PropertySet
    • 26.244. Namespace ArmoniK.Core.Common.Stream
    • 26.245. Namespace ArmoniK.Core.Common.Stream.Worker
    • 26.246. Interface IWorkerStreamHandler
    • 26.247. Class WorkerStreamHandler
    • 26.248. Namespace ArmoniK.Core.Common.Utils
    • 26.249. Class ActivityExt
    • 26.250. Class ActivitySourceExt
    • 26.251. Class ExceptionManager
    • 26.252. Class ExceptionManager.Options
    • 26.253. Class ExpressionsBuilders
    • 26.254. Class FileExt
    • 26.255. Class LocalIpFinder
    • 26.256. Class LoggerInit
    • 26.257. Class RendezvousChannel<T>
    • 26.258. Class ReplaceExpressionVisitor
    • 26.259. Class ReplaceParameterVisitor
    • 26.260. Namespace ArmoniK.Core.Common.gRPC
    • 26.261. Namespace ArmoniK.Core.Common.gRPC.Convertors
    • 26.262. Class OutputExt
    • 26.263. Class ResultExt
    • 26.264. Class ResultStatusExt
    • 26.265. Class SessionDataExt
    • 26.266. Class SessionStatusExt
    • 26.267. Class SessionTableExt
    • 26.268. Class TaskDataHolderExt
    • 26.269. Class TaskOptionsExt
    • 26.270. Class TaskStatusCountExt
    • 26.271. Class TaskStatusExt
    • 26.272. Class TaskTableExt
    • 26.273. Class EnumFieldExt
    • 26.274. Class ExceptionInterceptor
    • 26.275. Class ExpressionBuilders
    • 26.276. Class ExpressionExt
    • 26.277. Class FilterRangeExt
    • 26.278. Class GrpcHealthCheckServiceBase
    • 26.279. Class ListApplicationsRequestExt
    • 26.280. Class ListPartitionsRequestExt
    • 26.281. Class ListResultsRequestExt
    • 26.282. Class ListSessionsRequestExt
    • 26.283. Class ListTasksRequestExt
    • 26.284. Namespace ArmoniK.Core.Common.gRPC.Services
    • 26.285. Class GrpcAgentService
    • 26.286. Class GrpcApplicationsService
    • 26.287. Class GrpcAuthService
    • 26.288. Class GrpcEventsService
    • 26.289. Class GrpcHealthChecksService
    • 26.290. Class GrpcPartitionsService
    • 26.291. Class GrpcResultsService
    • 26.292. Class GrpcSessionsService
    • 26.293. Class GrpcSubmitterExtensions
    • 26.294. Class GrpcSubmitterService
    • 26.295. Class GrpcTasksService
    • 26.296. Class GrpcVersionsService
    • 26.297. Interface ISubmitter
    • 26.298. Class Submitter
    • 26.299. Class TaskRequest
    • 26.300. Class WatchToGrpc
    • 26.301. Class SessionFilterExt
    • 26.302. Class TaskFilterExt
    • 26.303. Namespace ArmoniK.Core.Common.gRPC.Validators
    • 26.304. Class CancelTasksRequestValidator
    • 26.305. Class CreateLargeTaskRequestValidator
    • 26.306. Class CreateSessionRequestValidator
    • 26.307. Class CreateSmallTaskRequestValidator
    • 26.308. Class CreateSmallTaskRequestValidator.TaskRequestValidator
    • 26.309. Class EventSubscriptionRequestValidator
    • 26.310. Class ListApplicationsRequestValidator
    • 26.311. Class ListPartitionsRequestValidator
    • 26.312. Class ListResultsRequestValidator
    • 26.313. Class ListSessionsRequestValidator
    • 26.314. Class ListTasksRequestValidator
    • 26.315. Class SessionFilterValidator
    • 26.316. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
    • 26.317. Class CreateSessionRequestValidator
    • 26.318. Class SubmitTasksRequestValidator
    • 26.319. Class TaskFilterValidator
    • 26.320. Class TaskOptionsValidator
    • 26.321. Namespace ArmoniK.Core.Compute
    • 26.322. Namespace ArmoniK.Core.Compute.PollingAgent
    • 26.323. Class Program
    • 26.324. Class Worker
    • 26.325. Namespace ArmoniK.Core.Control
    • 26.326. Namespace ArmoniK.Core.Control.Metrics
    • 26.327. Class ArmoniKMeter
    • 26.328. Namespace ArmoniK.Core.Control.Metrics.Options
    • 26.329. Class MetricsExporter
    • 26.330. Class Program
    • 26.331. Namespace ArmoniK.Core.Control.Submitter
    • 26.332. Class GrpcHealthCheckService
    • 26.333. Class Program
    • 26.334. Namespace ArmoniK.Core.ProfilingTools
    • 26.335. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
    • 26.336. Class ActivityExt
    • 26.337. Class MongoExporterHelperExtensions
    • 26.338. Class MongoExporterOptions
    • 26.339. Class OpenTelemetryData
    • 26.340. Class OpenTelemetryDataModelMapping
    • 26.341. Namespace ArmoniK.Core.Tests
    • 26.342. Namespace ArmoniK.Core.Tests.Queue
    • 26.343. Class QueueStorageTests
    • 26.344. Namespace ArmoniK.Core.Tests.UploadBench
    • 26.345. Namespace ArmoniK.Core.Tests.UploadBench.Options
    • 26.346. Class UploadBench
    • 26.347. Class UploadBenchClient
    • 26.348. Namespace ArmoniK.Core.Utils
    • 26.349. Class ByteArrayComparer
    • 26.350. Class CertificateValidator
    • 26.351. Class ConfigurationExt
    • 26.352. Class HealthCheck
    • 26.353. Class HealthCheckResultCombiner
    • 26.354. Class LoggerExt
    • 26.355. Class QueryableExt
    • 26.356. Class ServiceCollectionExt
    • 26.357. Namespace ArmoniK.Samples
    • 26.358. Namespace ArmoniK.Samples.Bench
    • 26.359. Namespace ArmoniK.Samples.Bench.Client
    • 26.360. Class ExecutionStats
    • 26.361. Namespace ArmoniK.Samples.Bench.Client.Options
    • 26.362. Class BenchOptions
    • 26.363. Namespace ArmoniK.Samples.Bench.Server
    • 26.364. Class BenchComputerService
    • 26.365. Namespace ArmoniK.Samples.CrashingWorker
    • 26.366. Namespace ArmoniK.Samples.CrashingWorker.Client
    • 26.367. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
    • 26.368. Class CrashingWorkerOptions
    • 26.369. Namespace ArmoniK.Samples.CrashingWorker.Server
    • 26.370. Class CrashingService
    • 26.371. Namespace ArmoniK.Samples.HtcMock
    • 26.372. Namespace ArmoniK.Samples.HtcMock.Client
    • 26.373. Class GridClient
    • 26.374. Class HtcMockClient
    • 26.375. Namespace ArmoniK.Samples.HtcMock.Client.Options
    • 26.376. Class HtcMock
    • 26.377. Class SessionClient
    • 26.378. Namespace ArmoniK.Samples.HtcMock.Server
    • 26.379. Class SampleComputerService
    • 26.380. Class Program
ArmoniK.Core
  • 26. API reference
  • 26.183. Class PostProcessingTaskQueue
  • Edit on GitHub

26.183. Class PostProcessingTaskQueue

Namespace: ArmoniK.Core.Common.Pollster
Assembly: ArmoniK.Core.Common.dll

Represents a queue for managing tasks that are in the post-processing stage in the ArmoniK Pollster. Inherits from and provides functionality specific to post-processing tasks.

public sealed class PostProcessingTaskQueue : TaskQueueBase

26.183.1. Inheritance

object ← RendezvousChannel<TaskHandler> ← TaskQueueBase ← PostProcessingTaskQueue

26.183.2. Inherited Members

RendezvousChannel<TaskHandler>.IsReaderClosed, RendezvousChannel<TaskHandler>.IsWriterClosed, RendezvousChannel<TaskHandler>.WriteAsync(TaskHandler, TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.ReadAsync(TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.CloseReader(), RendezvousChannel<TaskHandler>.CloseWriter(), RendezvousChannel<TaskHandler>.WaitForReader(TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.WaitForWriter(TimeSpan, CancellationToken), object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.ReferenceEquals(object?, object?), object.ToString()

Previous Next

© Copyright 2021-2026, ANEO.

Built with Sphinx using a theme provided by Read the Docs.