Interface IXperiflowConduitClient
Namespace: Workspace.XBR.Xperiflow.Core.RestApi.Conduit
Assembly: Xperiflow.dll
public interface IXperiflowConduitClient
Methods
GetTaskCollectionResourceAsync(XperiflowSessionInfo, string?, MemoizedCacheInfo?, CancellationToken)
TaskCollectionResource
Task<GetTaskCollectionResourceResponseContext> GetTaskCollectionResourceAsync(XperiflowSessionInfo x_OS_SessionInfo, string? query = null, MemoizedCacheInfo? cacheInfo = null, CancellationToken cancellationToken = default)
Remarks
Returns a list of all Xperiflow Tasks
Query Parameters
- query (optional/[str/]): Pinq query filter expression
Returns
- collection (List/[Dict/[str, Any/]/]): Each dictionary will be a model including the name, parent class, and all class attributes of the task.
Returns
Task
< Workspace.XBR.Xperiflow.Core.RestApi.Conduit.GetTaskCollectionResourceResponseContext >
ok
Parameters
Type | Name | Description |
---|---|---|
Workspace.XBR.Xperiflow.Core.Session.XperiflowSessionInfo | x_OS_SessionInfo | OneStream session info header object. |
System.String | query | A pinq query string. |
Workspace.XBR.Xperiflow.Utilities.Http.MemoizedCacheInfo | cacheInfo | |
System.Threading.CancellationToken | cancellationToken | A cancellation token that can be used by other objects or threads to receive notice of cancellation. |
Exceptions
Workspace.XBR.Xperiflow.Core.RestApi.Exceptions.XperiflowApiException A server side error occurred.
GetJobCollectionResourceAsync(XperiflowSessionInfo, string?, MemoizedCacheInfo?, CancellationToken)
JobCollectionResource
Task<GetJobCollectionResourceResponseContext> GetJobCollectionResourceAsync(XperiflowSessionInfo x_OS_SessionInfo, string? query = null, MemoizedCacheInfo? cacheInfo = null, CancellationToken cancellationToken = default)
Remarks
Returns a list of all Xperiflow Tasks
Query Parameters
- query (optional/[str/]): Pinq query filter expression
Returns
- collection (List/[Dict/[str, Any/]/]): Each dictionary will be a model including the name, parent class, and all class attributes of the task.
Returns
Task
< Workspace.XBR.Xperiflow.Core.RestApi.Conduit.GetJobCollectionResourceResponseContext >
ok
Parameters
Type | Name | Description |
---|---|---|
Workspace.XBR.Xperiflow.Core.Session.XperiflowSessionInfo | x_OS_SessionInfo | OneStream session info header object. |
System.String | query | A pinq query string. |
Workspace.XBR.Xperiflow.Utilities.Http.MemoizedCacheInfo | cacheInfo | |
System.Threading.CancellationToken | cancellationToken | A cancellation token that can be used by other objects or threads to receive notice of cancellation. |
Exceptions
Workspace.XBR.Xperiflow.Core.RestApi.Exceptions.XperiflowApiException A server side error occurred.
GetActivityStatusesResourceAsync(XperiflowSessionInfo, MemoizedCacheInfo?, CancellationToken)
ActivityStatusesResource
Task<GetActivityStatusesResourceResponseContext> GetActivityStatusesResourceAsync(XperiflowSessionInfo x_OS_SessionInfo, MemoizedCacheInfo? cacheInfo = null, CancellationToken cancellationToken = default)
Remarks
Retrieve the viable ActivityStatusOptions that can be used to query the JobList API.
Returns
Task
< Workspace.XBR.Xperiflow.Core.RestApi.Conduit.GetActivityStatusesResourceResponseContext >
ok
Parameters
Type | Name | Description |
---|---|---|
Workspace.XBR.Xperiflow.Core.Session.XperiflowSessionInfo | x_OS_SessionInfo | OneStream session info header object. |
Workspace.XBR.Xperiflow.Utilities.Http.MemoizedCacheInfo | cacheInfo | |
System.Threading.CancellationToken | cancellationToken | A cancellation token that can be used by other objects or threads to receive notice of cancellation. |
Exceptions
Workspace.XBR.Xperiflow.Core.RestApi.Exceptions.XperiflowApiException A server side error occurred.
PostBackgroundJobCreationResourceAsync(XperiflowSessionInfo, BodyBackgroundJobCreationContext, MemoizedCacheInfo?, CancellationToken)
BackgroundJobCreationResource
Task<PostBackgroundJobCreationResourceResponseContext> PostBackgroundJobCreationResourceAsync(XperiflowSessionInfo x_OS_SessionInfo, BodyBackgroundJobCreationContext body, MemoizedCacheInfo? cacheInfo = null, CancellationToken cancellationToken = default)
Remarks
Submit a XperiFlow Python Job to be processed by the Conduit Orchestration Framework as a background job. Background jobs will be executed immediately and do not occupy an orchestrator
Supported Activity Types:
- Target Data Validation
-
activity_type: ScenarioExcelCreation
-
app: sml
-
comm_metadata_json:
-
task_storage
-
scenario_id: int
-
fill_with_forecasted_data: bool
-
hashkeys: Optional[set[str]] = None
-
-
-
Returns
Task
< Workspace.XBR.Xperiflow.Core.RestApi.Conduit.PostBackgroundJobCreationResourceResponseContext >
created
Parameters
Type | Name | Description |
---|---|---|
Workspace.XBR.Xperiflow.Core.Session.XperiflowSessionInfo | x_OS_SessionInfo | OneStream session info header object. |
Workspace.XBR.Xperiflow.Core.RestApi.Conduit.BodyBackgroundJobCreationContext | body | |
Workspace.XBR.Xperiflow.Utilities.Http.MemoizedCacheInfo | cacheInfo | |
System.Threading.CancellationToken | cancellationToken | A cancellation token that can be used by other objects or threads to receive notice of cancellation. |
Exceptions
Workspace.XBR.Xperiflow.Core.RestApi.Exceptions.XperiflowApiException A server side error occurred.
GetBackgroundJobResultResourceAsync(XperiflowSessionInfo, int, MemoizedCacheInfo?, CancellationToken)
BackgroundJobResultResource
Task<GetBackgroundJobResultResourceResponseContext> GetBackgroundJobResultResourceAsync(XperiflowSessionInfo x_OS_SessionInfo, int job_id, MemoizedCacheInfo? cacheInfo = null, CancellationToken cancellationToken = default)
Remarks
Gets the result of the BackgroundJob.
Returns
Task
< Workspace.XBR.Xperiflow.Core.RestApi.Conduit.GetBackgroundJobResultResourceResponseContext >
created
Parameters
Type | Name | Description |
---|---|---|
Workspace.XBR.Xperiflow.Core.Session.XperiflowSessionInfo | x_OS_SessionInfo | OneStream session info header object. |
System.Int32 | job_id | the unique identifier associated with the job. |
Workspace.XBR.Xperiflow.Utilities.Http.MemoizedCacheInfo | cacheInfo | |
System.Threading.CancellationToken | cancellationToken | A cancellation token that can be used by other objects or threads to receive notice of cancellation. |
Exceptions
Workspace.XBR.Xperiflow.Core.RestApi.Exceptions.XperiflowApiException A server side error occurred.
PostJobCancellationResourceAsync(XperiflowSessionInfo, int, MemoizedCacheInfo?, CancellationToken)
JobCancellationResource
Task<NullableIntItemIdentifierXperiflowResponseContext> PostJobCancellationResourceAsync(XperiflowSessionInfo x_OS_SessionInfo, int job_id, MemoizedCacheInfo? cacheInfo = null, CancellationToken cancellationToken = default)
Remarks
Cancells the given job ID. If the job is queued it will be marked as "usercancelled" if it is running, it will be marked as "pending_usercancelled". If it is already in a stopping state it will not be re-cancelled and modified result will be false.
Returns
Task
< Workspace.XBR.Xperiflow.Core.RestApi.Conduit.NullableIntItemIdentifierXperiflowResponseContext >
ok
Parameters
Type | Name | Description |
---|---|---|
Workspace.XBR.Xperiflow.Core.Session.XperiflowSessionInfo | x_OS_SessionInfo | OneStream session info header object. |
System.Int32 | job_id | the unique identifier associated with the job. |
Workspace.XBR.Xperiflow.Utilities.Http.MemoizedCacheInfo | cacheInfo | |
System.Threading.CancellationToken | cancellationToken | A cancellation token that can be used by other objects or threads to receive notice of cancellation. |
Exceptions
Workspace.XBR.Xperiflow.Core.RestApi.Exceptions.XperiflowApiException A server side error occurred.
GetJobsResourceAsync(XperiflowSessionInfo, IEnumerable<string>?, string?, int?, int?, string?, MemoizedCacheInfo?, CancellationToken)
JobsResource
Task<GetJobsResourceResponseContext> GetJobsResourceAsync(XperiflowSessionInfo x_OS_SessionInfo, IEnumerable<string>? fields = null, string? filter = null, int? page = null, int? records_per_page = null, string? order_bys = null, MemoizedCacheInfo? cacheInfo = null, CancellationToken cancellationToken = default)