# This file was generated by the Julia OpenAPI Code Generator
# Do not modify this file directly. Modify the OpenAPI specification instead.
struct DefaultApi <: OpenAPI.APIClientImpl
client::OpenAPI.Clients.Client
end
"""
The default API base path for APIs in `DefaultApi`.
This can be used to construct the `OpenAPI.Clients.Client` instance.
"""
basepath(::Type{ DefaultApi }) = "http://localhost/torc-service/v1"
const _returntypes_add_user_to_group_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => UserGroupMembershipModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("409", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_add_user_to_group(_api::DefaultApi, id::Int64, body::UserGroupMembershipModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_add_user_to_group_DefaultApi, "/access_groups/{id}/members", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Add a user to an access group.
Add a user to an access group.
Params:
- id::Int64 (required)
- body::UserGroupMembershipModel (required)
Return: UserGroupMembershipModel, OpenAPI.Clients.ApiResponse
"""
function add_user_to_group(_api::DefaultApi, id::Int64, body::UserGroupMembershipModel; _mediaType=nothing)
_ctx = _oacinternal_add_user_to_group(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function add_user_to_group(_api::DefaultApi, response_stream::Channel, id::Int64, body::UserGroupMembershipModel; _mediaType=nothing)
_ctx = _oacinternal_add_user_to_group(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_add_workflow_to_group_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowAccessGroupModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("409", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_add_workflow_to_group(_api::DefaultApi, id::Int64, body::WorkflowAccessGroupModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_add_workflow_to_group_DefaultApi, "/workflows/{id}/access_groups", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Grant an access group access to a workflow.
Grant an access group access to a workflow.
Params:
- id::Int64 (required)
- body::WorkflowAccessGroupModel (required)
Return: WorkflowAccessGroupModel, OpenAPI.Clients.ApiResponse
"""
function add_workflow_to_group(_api::DefaultApi, id::Int64, body::WorkflowAccessGroupModel; _mediaType=nothing)
_ctx = _oacinternal_add_workflow_to_group(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function add_workflow_to_group(_api::DefaultApi, response_stream::Channel, id::Int64, body::WorkflowAccessGroupModel; _mediaType=nothing)
_ctx = _oacinternal_add_workflow_to_group(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_cancel_workflow_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_cancel_workflow(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_cancel_workflow_DefaultApi, "/workflows/{id}/cancel", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Cancel a workflow. Workers will detect the status change and cancel jobs.
Cancel a workflow. Workers will detect the status change and cancel jobs.
Params:
- id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function cancel_workflow(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_cancel_workflow(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function cancel_workflow(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_cancel_workflow(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_check_workflow_access_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => AccessCheckResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_check_workflow_access(_api::DefaultApi, workflow_id::Int64, user_name::String; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_check_workflow_access_DefaultApi, "/access_check/{workflow_id}/{user_name}", [])
OpenAPI.Clients.set_param(_ctx.path, "workflow_id", workflow_id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "user_name", user_name) # type String
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Check if a user can access a workflow.
Check if a user can access a workflow.
Params:
- workflow_id::Int64 (required)
- user_name::String (required)
Return: AccessCheckResponse, OpenAPI.Clients.ApiResponse
"""
function check_workflow_access(_api::DefaultApi, workflow_id::Int64, user_name::String; _mediaType=nothing)
_ctx = _oacinternal_check_workflow_access(_api, workflow_id, user_name; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function check_workflow_access(_api::DefaultApi, response_stream::Channel, workflow_id::Int64, user_name::String; _mediaType=nothing)
_ctx = _oacinternal_check_workflow_access(_api, workflow_id, user_name; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_claim_action_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ClaimAction200Response,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("409", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_claim_action(_api::DefaultApi, id::Int64, action_id::Int64, body::ClaimActionRequest; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_claim_action_DefaultApi, "/workflows/{id}/actions/{action_id}/claim", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "action_id", action_id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Atomically claim a workflow action.
Atomically claim a workflow action for execution by a compute node.
Params:
- id::Int64 (required)
- action_id::Int64 (required)
- body::ClaimActionRequest (required)
Return: ClaimAction200Response, OpenAPI.Clients.ApiResponse
"""
function claim_action(_api::DefaultApi, id::Int64, action_id::Int64, body::ClaimActionRequest; _mediaType=nothing)
_ctx = _oacinternal_claim_action(_api, id, action_id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function claim_action(_api::DefaultApi, response_stream::Channel, id::Int64, action_id::Int64, body::ClaimActionRequest; _mediaType=nothing)
_ctx = _oacinternal_claim_action(_api, id, action_id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_claim_jobs_based_on_resources_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ClaimJobsBasedOnResourcesResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_claim_jobs_based_on_resources(_api::DefaultApi, id::Int64, limit::Int64, body::ComputeNodesResources; sort_method=nothing, strict_scheduler_match=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_claim_jobs_based_on_resources_DefaultApi, "/workflows/{id}/claim_jobs_based_on_resources/{limit}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "limit", limit) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_method", sort_method; style="form", is_explode=true) # type JobsSortMethod
OpenAPI.Clients.set_param(_ctx.query, "strict_scheduler_match", strict_scheduler_match; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Return jobs that are ready for submission and meet worker resource requirements. Set status to pending.
Return jobs that are ready for submission and meet worker resource requirements. Set status to pending.
Params:
- id::Int64 (required)
- limit::Int64 (required)
- body::ComputeNodesResources (required)
- sort_method::JobsSortMethod
- strict_scheduler_match::Bool
Return: ClaimJobsBasedOnResourcesResponse, OpenAPI.Clients.ApiResponse
"""
function claim_jobs_based_on_resources(_api::DefaultApi, id::Int64, limit::Int64, body::ComputeNodesResources; sort_method=nothing, strict_scheduler_match=nothing, _mediaType=nothing)
_ctx = _oacinternal_claim_jobs_based_on_resources(_api, id, limit, body; sort_method=sort_method, strict_scheduler_match=strict_scheduler_match, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function claim_jobs_based_on_resources(_api::DefaultApi, response_stream::Channel, id::Int64, limit::Int64, body::ComputeNodesResources; sort_method=nothing, strict_scheduler_match=nothing, _mediaType=nothing)
_ctx = _oacinternal_claim_jobs_based_on_resources(_api, id, limit, body; sort_method=sort_method, strict_scheduler_match=strict_scheduler_match, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_claim_next_jobs_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ClaimNextJobsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_claim_next_jobs(_api::DefaultApi, id::Int64; limit=nothing, body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_claim_next_jobs_DefaultApi, "/workflows/{id}/claim_next_jobs", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Return user-requested number of jobs that are ready for submission. Sets status to pending.
Return user-requested number of jobs that are ready for submission. Sets status to pending.
Params:
- id::Int64 (required)
- limit::Int64
- body::Any
Return: ClaimNextJobsResponse, OpenAPI.Clients.ApiResponse
"""
function claim_next_jobs(_api::DefaultApi, id::Int64; limit=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_claim_next_jobs(_api, id; limit=limit, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function claim_next_jobs(_api::DefaultApi, response_stream::Channel, id::Int64; limit=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_claim_next_jobs(_api, id; limit=limit, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_complete_job_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_complete_job(_api::DefaultApi, id::Int64, status::JobStatus, run_id::Int64, body::ResultModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_complete_job_DefaultApi, "/jobs/{id}/complete_job/{status}/{run_id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "status", status) # type JobStatus
OpenAPI.Clients.set_param(_ctx.path, "run_id", run_id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Complete a job, connect it to a result, and manage side effects.
Complete a job, connect it to a result, and manage side effects.
Params:
- id::Int64 (required)
- status::JobStatus (required)
- run_id::Int64 (required)
- body::ResultModel (required)
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function complete_job(_api::DefaultApi, id::Int64, status::JobStatus, run_id::Int64, body::ResultModel; _mediaType=nothing)
_ctx = _oacinternal_complete_job(_api, id, status, run_id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function complete_job(_api::DefaultApi, response_stream::Channel, id::Int64, status::JobStatus, run_id::Int64, body::ResultModel; _mediaType=nothing)
_ctx = _oacinternal_complete_job(_api, id, status, run_id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_access_group_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => AccessGroupModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("409", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_access_group(_api::DefaultApi, body::AccessGroupModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_access_group_DefaultApi, "/access_groups", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Create a new access group.
Create a new access group.
Params:
- body::AccessGroupModel (required)
Return: AccessGroupModel, OpenAPI.Clients.ApiResponse
"""
function create_access_group(_api::DefaultApi, body::AccessGroupModel; _mediaType=nothing)
_ctx = _oacinternal_create_access_group(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_access_group(_api::DefaultApi, response_stream::Channel, body::AccessGroupModel; _mediaType=nothing)
_ctx = _oacinternal_create_access_group(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ComputeNodeModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_compute_node(_api::DefaultApi, body::ComputeNodeModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_compute_node_DefaultApi, "/compute_nodes", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a compute node.
Store a compute node.
Params:
- body::ComputeNodeModel (required)
Return: ComputeNodeModel, OpenAPI.Clients.ApiResponse
"""
function create_compute_node(_api::DefaultApi, body::ComputeNodeModel; _mediaType=nothing)
_ctx = _oacinternal_create_compute_node(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_compute_node(_api::DefaultApi, response_stream::Channel, body::ComputeNodeModel; _mediaType=nothing)
_ctx = _oacinternal_create_compute_node(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_event_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => EventModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_event(_api::DefaultApi, body::EventModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_event_DefaultApi, "/events", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store an event.
Store an event.
Params:
- body::EventModel (required)
Return: EventModel, OpenAPI.Clients.ApiResponse
"""
function create_event(_api::DefaultApi, body::EventModel; _mediaType=nothing)
_ctx = _oacinternal_create_event(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_event(_api::DefaultApi, response_stream::Channel, body::EventModel; _mediaType=nothing)
_ctx = _oacinternal_create_event(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_failure_handler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => FailureHandlerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_failure_handler(_api::DefaultApi, body::FailureHandlerModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_failure_handler_DefaultApi, "/failure_handlers", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Create a failure handler.
Create a failure handler with rules for automatic job retry.
Params:
- body::FailureHandlerModel (required)
Return: FailureHandlerModel, OpenAPI.Clients.ApiResponse
"""
function create_failure_handler(_api::DefaultApi, body::FailureHandlerModel; _mediaType=nothing)
_ctx = _oacinternal_create_failure_handler(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_failure_handler(_api::DefaultApi, response_stream::Channel, body::FailureHandlerModel; _mediaType=nothing)
_ctx = _oacinternal_create_failure_handler(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_file_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => FileModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_file(_api::DefaultApi, body::FileModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_file_DefaultApi, "/files", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a file.
Store a file.
Params:
- body::FileModel (required)
Return: FileModel, OpenAPI.Clients.ApiResponse
"""
function create_file(_api::DefaultApi, body::FileModel; _mediaType=nothing)
_ctx = _oacinternal_create_file(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_file(_api::DefaultApi, response_stream::Channel, body::FileModel; _mediaType=nothing)
_ctx = _oacinternal_create_file(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_job_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_job(_api::DefaultApi, body::JobModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_job_DefaultApi, "/jobs", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a job.
Store a job.
Params:
- body::JobModel (required)
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function create_job(_api::DefaultApi, body::JobModel; _mediaType=nothing)
_ctx = _oacinternal_create_job(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_job(_api::DefaultApi, response_stream::Channel, body::JobModel; _mediaType=nothing)
_ctx = _oacinternal_create_job(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_jobs_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => CreateJobsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_jobs(_api::DefaultApi, body::JobsModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_jobs_DefaultApi, "/bulk_jobs", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Create jobs in bulk. Recommended max job count of 10,000.
Create jobs in bulk. Recommended max job count of 10,000.
Params:
- body::JobsModel (required)
Return: CreateJobsResponse, OpenAPI.Clients.ApiResponse
"""
function create_jobs(_api::DefaultApi, body::JobsModel; _mediaType=nothing)
_ctx = _oacinternal_create_jobs(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_jobs(_api::DefaultApi, response_stream::Channel, body::JobsModel; _mediaType=nothing)
_ctx = _oacinternal_create_jobs(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_local_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => LocalSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_local_scheduler(_api::DefaultApi, body::LocalSchedulerModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_local_scheduler_DefaultApi, "/local_schedulers", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a local scheduler.
Store a local scheduler. table.
Params:
- body::LocalSchedulerModel (required)
Return: LocalSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function create_local_scheduler(_api::DefaultApi, body::LocalSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_create_local_scheduler(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_local_scheduler(_api::DefaultApi, response_stream::Channel, body::LocalSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_create_local_scheduler(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_remote_workers_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Vector{RemoteWorkerModel},
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_remote_workers(_api::DefaultApi, id::Int64, workers::Vector{String}; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_remote_workers_DefaultApi, "/workflows/{id}/remote_workers", [], workers)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store remote workers for a workflow.
Store remote workers for a workflow.
Params:
- id::Int64 (required)
- workers::Vector{String} (required)
Return: Vector{RemoteWorkerModel}, OpenAPI.Clients.ApiResponse
"""
function create_remote_workers(_api::DefaultApi, id::Int64, workers::Vector{String}; _mediaType=nothing)
_ctx = _oacinternal_create_remote_workers(_api, id, workers; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_remote_workers(_api::DefaultApi, response_stream::Channel, id::Int64, workers::Vector{String}; _mediaType=nothing)
_ctx = _oacinternal_create_remote_workers(_api, id, workers; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_resource_requirements_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResourceRequirementsModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_resource_requirements(_api::DefaultApi, body::ResourceRequirementsModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_resource_requirements_DefaultApi, "/resource_requirements", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store one resource requirements record.
Store one resource requirements definition.
Params:
- body::ResourceRequirementsModel (required)
Return: ResourceRequirementsModel, OpenAPI.Clients.ApiResponse
"""
function create_resource_requirements(_api::DefaultApi, body::ResourceRequirementsModel; _mediaType=nothing)
_ctx = _oacinternal_create_resource_requirements(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_resource_requirements(_api::DefaultApi, response_stream::Channel, body::ResourceRequirementsModel; _mediaType=nothing)
_ctx = _oacinternal_create_resource_requirements(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_result_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResultModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_result(_api::DefaultApi, body::ResultModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_result_DefaultApi, "/results", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a job result.
Store a job result.
Params:
- body::ResultModel (required)
Return: ResultModel, OpenAPI.Clients.ApiResponse
"""
function create_result(_api::DefaultApi, body::ResultModel; _mediaType=nothing)
_ctx = _oacinternal_create_result(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_result(_api::DefaultApi, response_stream::Channel, body::ResultModel; _mediaType=nothing)
_ctx = _oacinternal_create_result(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_ro_crate_entity_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => RoCrateEntityModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_ro_crate_entity(_api::DefaultApi, body::RoCrateEntityModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_ro_crate_entity_DefaultApi, "/ro_crate_entities", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Create a new RO-Crate entity.
Create a new RO-Crate entity.
Params:
- body::RoCrateEntityModel (required)
Return: RoCrateEntityModel, OpenAPI.Clients.ApiResponse
"""
function create_ro_crate_entity(_api::DefaultApi, body::RoCrateEntityModel; _mediaType=nothing)
_ctx = _oacinternal_create_ro_crate_entity(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_ro_crate_entity(_api::DefaultApi, response_stream::Channel, body::RoCrateEntityModel; _mediaType=nothing)
_ctx = _oacinternal_create_ro_crate_entity(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_scheduled_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ScheduledComputeNodesModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_scheduled_compute_node(_api::DefaultApi, body::ScheduledComputeNodesModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_scheduled_compute_node_DefaultApi, "/scheduled_compute_nodes", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a scheduled compute node.
Store a scheduled compute node.
Params:
- body::ScheduledComputeNodesModel (required)
Return: ScheduledComputeNodesModel, OpenAPI.Clients.ApiResponse
"""
function create_scheduled_compute_node(_api::DefaultApi, body::ScheduledComputeNodesModel; _mediaType=nothing)
_ctx = _oacinternal_create_scheduled_compute_node(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_scheduled_compute_node(_api::DefaultApi, response_stream::Channel, body::ScheduledComputeNodesModel; _mediaType=nothing)
_ctx = _oacinternal_create_scheduled_compute_node(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_slurm_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => SlurmSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_slurm_scheduler(_api::DefaultApi, body::SlurmSchedulerModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_slurm_scheduler_DefaultApi, "/slurm_schedulers", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a Slurm compute node configuration.
Store a Slurm compute node configuration.
Params:
- body::SlurmSchedulerModel (required)
Return: SlurmSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function create_slurm_scheduler(_api::DefaultApi, body::SlurmSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_create_slurm_scheduler(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_slurm_scheduler(_api::DefaultApi, response_stream::Channel, body::SlurmSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_create_slurm_scheduler(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_slurm_stats_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => SlurmStatsModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_slurm_stats(_api::DefaultApi, body::SlurmStatsModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_slurm_stats_DefaultApi, "/slurm_stats", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store Slurm accounting stats for a job step.
Store Slurm accounting stats collected via sacct for a job step.
Params:
- body::SlurmStatsModel (required)
Return: SlurmStatsModel, OpenAPI.Clients.ApiResponse
"""
function create_slurm_stats(_api::DefaultApi, body::SlurmStatsModel; _mediaType=nothing)
_ctx = _oacinternal_create_slurm_stats(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_slurm_stats(_api::DefaultApi, response_stream::Channel, body::SlurmStatsModel; _mediaType=nothing)
_ctx = _oacinternal_create_slurm_stats(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_user_data_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => UserDataModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_user_data(_api::DefaultApi, body::UserDataModel; consumer_job_id=nothing, producer_job_id=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_user_data_DefaultApi, "/user_data", [], body)
OpenAPI.Clients.set_param(_ctx.query, "consumer_job_id", consumer_job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "producer_job_id", producer_job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a user data record.
Store a user data record.
Params:
- body::UserDataModel (required)
- consumer_job_id::Int64
- producer_job_id::Int64
Return: UserDataModel, OpenAPI.Clients.ApiResponse
"""
function create_user_data(_api::DefaultApi, body::UserDataModel; consumer_job_id=nothing, producer_job_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_create_user_data(_api, body; consumer_job_id=consumer_job_id, producer_job_id=producer_job_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_user_data(_api::DefaultApi, response_stream::Channel, body::UserDataModel; consumer_job_id=nothing, producer_job_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_create_user_data(_api, body; consumer_job_id=consumer_job_id, producer_job_id=producer_job_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_workflow_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_workflow(_api::DefaultApi, body::WorkflowModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_workflow_DefaultApi, "/workflows", [], body)
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Store a workflow.
Store a workflow.
Params:
- body::WorkflowModel (required)
Return: WorkflowModel, OpenAPI.Clients.ApiResponse
"""
function create_workflow(_api::DefaultApi, body::WorkflowModel; _mediaType=nothing)
_ctx = _oacinternal_create_workflow(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_workflow(_api::DefaultApi, response_stream::Channel, body::WorkflowModel; _mediaType=nothing)
_ctx = _oacinternal_create_workflow(_api, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_create_workflow_action_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowActionModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_create_workflow_action(_api::DefaultApi, id::Int64, body::WorkflowActionModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_workflow_action_DefaultApi, "/workflows/{id}/actions", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Create a workflow action.
Create a workflow action.
Params:
- id::Int64 (required)
- body::WorkflowActionModel (required)
Return: WorkflowActionModel, OpenAPI.Clients.ApiResponse
"""
function create_workflow_action(_api::DefaultApi, id::Int64, body::WorkflowActionModel; _mediaType=nothing)
_ctx = _oacinternal_create_workflow_action(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function create_workflow_action(_api::DefaultApi, response_stream::Channel, id::Int64, body::WorkflowActionModel; _mediaType=nothing)
_ctx = _oacinternal_create_workflow_action(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_access_group_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => AccessGroupModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_access_group(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_access_group_DefaultApi, "/access_groups/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete an access group.
Delete an access group.
Params:
- id::Int64 (required)
- body::Any
Return: AccessGroupModel, OpenAPI.Clients.ApiResponse
"""
function delete_access_group(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_access_group(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_access_group(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_access_group(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_all_user_data_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_all_user_data(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_all_user_data_DefaultApi, "/user_data", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all user data records for one workflow.
Delete all user data records for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_all_user_data(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_all_user_data(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_all_user_data(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_all_user_data(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ComputeNodeModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_compute_node(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_compute_node_DefaultApi, "/compute_nodes/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a compute node.
Delete a compute node.
Params:
- id::Int64 (required)
- body::Any
Return: ComputeNodeModel, OpenAPI.Clients.ApiResponse
"""
function delete_compute_node(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_compute_node(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_compute_node(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_compute_node(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_compute_nodes_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_compute_nodes(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_compute_nodes_DefaultApi, "/compute_nodes", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all compute node records for one workflow.
Delete all compute node records for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_compute_nodes(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_compute_nodes(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_compute_nodes(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_compute_nodes(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_event_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => EventModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_event(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_event_DefaultApi, "/events/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete an event.
Deletes an event.
Params:
- id::Int64 (required)
- body::Any
Return: EventModel, OpenAPI.Clients.ApiResponse
"""
function delete_event(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_event(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_event(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_event(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_events_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_events(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_events_DefaultApi, "/events", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all events for one workflow.
Delete all events for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_events(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_events(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_events(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_events(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_failure_handler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => FailureHandlerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_failure_handler(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_failure_handler_DefaultApi, "/failure_handlers/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a failure handler.
Delete a failure handler.
Params:
- id::Int64 (required)
- body::Any
Return: FailureHandlerModel, OpenAPI.Clients.ApiResponse
"""
function delete_failure_handler(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_failure_handler(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_failure_handler(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_failure_handler(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_file_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => FileModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_file(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_file_DefaultApi, "/files/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a file.
Delete a file.
Params:
- id::Int64 (required)
- body::Any
Return: FileModel, OpenAPI.Clients.ApiResponse
"""
function delete_file(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_file(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_file(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_file(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_files_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_files(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_files_DefaultApi, "/files", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all files for one workflow.
Delete all files for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_files(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_files(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_files(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_files(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_job_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_job(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_job_DefaultApi, "/jobs/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a job.
Delete a job.
Params:
- id::Int64 (required)
- body::Any
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function delete_job(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_job(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_job(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_job(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_jobs_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_jobs(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_jobs_DefaultApi, "/jobs", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all jobs for one workflow.
Delete all jobs for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_jobs(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_jobs(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_jobs(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_jobs(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_local_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => LocalSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_local_scheduler(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_local_scheduler_DefaultApi, "/local_schedulers/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a local scheduler.
Delete a local scheduler.
Params:
- id::Int64 (required)
- body::Any
Return: LocalSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function delete_local_scheduler(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_local_scheduler(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_local_scheduler(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_local_scheduler(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_local_schedulers_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_local_schedulers(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_local_schedulers_DefaultApi, "/local_schedulers", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all local schedulers for one workflow.
Delete all local schedulers for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_local_schedulers(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_local_schedulers(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_local_schedulers(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_local_schedulers(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_remote_worker_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => RemoteWorkerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_remote_worker(_api::DefaultApi, id::Int64, worker::String; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_remote_worker_DefaultApi, "/workflows/{id}/remote_workers/{worker}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "worker", worker) # type String
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Delete a remote worker from a workflow.
Delete a remote worker from a workflow.
Params:
- id::Int64 (required)
- worker::String (required)
Return: RemoteWorkerModel, OpenAPI.Clients.ApiResponse
"""
function delete_remote_worker(_api::DefaultApi, id::Int64, worker::String; _mediaType=nothing)
_ctx = _oacinternal_delete_remote_worker(_api, id, worker; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_remote_worker(_api::DefaultApi, response_stream::Channel, id::Int64, worker::String; _mediaType=nothing)
_ctx = _oacinternal_delete_remote_worker(_api, id, worker; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_resource_requirement_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResourceRequirementsModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_resource_requirement(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_resource_requirement_DefaultApi, "/resource_requirements/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a resource requirements record.
Delete a resource requirements record.
Params:
- id::Int64 (required)
- body::Any
Return: ResourceRequirementsModel, OpenAPI.Clients.ApiResponse
"""
function delete_resource_requirement(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_resource_requirement(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_resource_requirement(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_resource_requirement(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_resource_requirements_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_resource_requirements(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_resource_requirements_DefaultApi, "/resource_requirements", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all resource requirements records for one workflow.
Delete all resource requirements records for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_resource_requirements(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_resource_requirements(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_resource_requirements(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_resource_requirements(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_result_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResultModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_result(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_result_DefaultApi, "/results/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a job result.
Delete a job result.
Params:
- id::Int64 (required)
- body::Any
Return: ResultModel, OpenAPI.Clients.ApiResponse
"""
function delete_result(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_result(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_result(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_result(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_results_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_results(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_results_DefaultApi, "/results", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all job results for one workflow.
Delete all job results for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_results(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_results(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_results(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_results(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_ro_crate_entities_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => DeleteRoCrateEntities200Response,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_ro_crate_entities(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_ro_crate_entities_DefaultApi, "/workflows/{id}/ro_crate_entities", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all RO-Crate entities for a workflow.
Delete all RO-Crate entities for a workflow.
Params:
- id::Int64 (required)
- body::Any
Return: DeleteRoCrateEntities200Response, OpenAPI.Clients.ApiResponse
"""
function delete_ro_crate_entities(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_ro_crate_entities(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_ro_crate_entities(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_ro_crate_entities(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_ro_crate_entity_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => DeleteRoCrateEntity200Response,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_ro_crate_entity(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_ro_crate_entity_DefaultApi, "/ro_crate_entities/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete an RO-Crate entity.
Delete an RO-Crate entity.
Params:
- id::Int64 (required)
- body::Any
Return: DeleteRoCrateEntity200Response, OpenAPI.Clients.ApiResponse
"""
function delete_ro_crate_entity(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_ro_crate_entity(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_ro_crate_entity(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_ro_crate_entity(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_scheduled_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ScheduledComputeNodesModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_scheduled_compute_node(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_scheduled_compute_node_DefaultApi, "/scheduled_compute_nodes/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a scheduled compute node.
Delete a scheduled compute node.
Params:
- id::Int64 (required)
- body::Any
Return: ScheduledComputeNodesModel, OpenAPI.Clients.ApiResponse
"""
function delete_scheduled_compute_node(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_scheduled_compute_node(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_scheduled_compute_node(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_scheduled_compute_node(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_scheduled_compute_nodes_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_scheduled_compute_nodes(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_scheduled_compute_nodes_DefaultApi, "/scheduled_compute_nodes", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete all scheduled compute node records for one workflow.
Delete all scheduled compute node records for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_scheduled_compute_nodes(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_scheduled_compute_nodes(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_scheduled_compute_nodes(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_scheduled_compute_nodes(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_slurm_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => SlurmSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_slurm_scheduler(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_slurm_scheduler_DefaultApi, "/slurm_schedulers/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete Slurm compute node configuration.
Delete Slurm compute node configuration.
Params:
- id::Int64 (required)
- body::Any
Return: SlurmSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function delete_slurm_scheduler(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_slurm_scheduler(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_slurm_scheduler(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_slurm_scheduler(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_slurm_schedulers_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_slurm_schedulers(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_slurm_schedulers_DefaultApi, "/slurm_schedulers", [], body)
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all Slurm compute node configurations for one workflow.
Retrieve all Slurm compute node configurations for one workflow.
Params:
- workflow_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function delete_slurm_schedulers(_api::DefaultApi, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_slurm_schedulers(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_slurm_schedulers(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_slurm_schedulers(_api, workflow_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_user_data_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => UserDataModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_user_data(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_user_data_DefaultApi, "/user_data/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a user data record.
Delete a user data record.
Params:
- id::Int64 (required)
- body::Any
Return: UserDataModel, OpenAPI.Clients.ApiResponse
"""
function delete_user_data(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_user_data(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_user_data(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_user_data(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_delete_workflow_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_delete_workflow(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_delete_workflow_DefaultApi, "/workflows/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Delete a workflow.
Delete a workflow.
Params:
- id::Int64 (required)
- body::Any
Return: WorkflowModel, OpenAPI.Clients.ApiResponse
"""
function delete_workflow(_api::DefaultApi, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_workflow(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function delete_workflow(_api::DefaultApi, response_stream::Channel, id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_delete_workflow(_api, id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_access_group_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => AccessGroupModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_access_group(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_access_group_DefaultApi, "/access_groups/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Get an access group by ID.
Get an access group by ID.
Params:
- id::Int64 (required)
Return: AccessGroupModel, OpenAPI.Clients.ApiResponse
"""
function get_access_group(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_access_group(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_access_group(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_access_group(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ComputeNodeModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_compute_node(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_compute_node_DefaultApi, "/compute_nodes/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a compute node by ID.
Retrieve a compute node by ID.
Params:
- id::Int64 (required)
Return: ComputeNodeModel, OpenAPI.Clients.ApiResponse
"""
function get_compute_node(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_compute_node(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_compute_node(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_compute_node(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_event_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => EventModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_event(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_event_DefaultApi, "/events/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve an event by ID.
Retrieve an event by ID.
Params:
- id::Int64 (required)
Return: EventModel, OpenAPI.Clients.ApiResponse
"""
function get_event(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_event(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_event(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_event(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_failure_handler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => FailureHandlerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_failure_handler(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_failure_handler_DefaultApi, "/failure_handlers/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Get a failure handler by ID.
Retrieve a failure handler by ID.
Params:
- id::Int64 (required)
Return: FailureHandlerModel, OpenAPI.Clients.ApiResponse
"""
function get_failure_handler(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_failure_handler(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_failure_handler(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_failure_handler(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_file_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => FileModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_file(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_file_DefaultApi, "/files/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a file.
Retrieve a file.
Params:
- id::Int64 (required)
Return: FileModel, OpenAPI.Clients.ApiResponse
"""
function get_file(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_file(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_file(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_file(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_job_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_job(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_job_DefaultApi, "/jobs/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a job.
Retrieve a job.
Params:
- id::Int64 (required)
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function get_job(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_job(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_job(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_job(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_latest_event_timestamp_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_latest_event_timestamp(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_latest_event_timestamp_DefaultApi, "/workflows/{id}/latest_event_timestamp", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Return the timestamp of the latest event in ms since the epoch in UTC.
Return the timestamp of the latest event in ms since the epoch in UTC.
Params:
- id::Int64 (required)
Return: Any, OpenAPI.Clients.ApiResponse
"""
function get_latest_event_timestamp(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_latest_event_timestamp(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_latest_event_timestamp(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_latest_event_timestamp(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_local_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => LocalSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_local_scheduler(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_local_scheduler_DefaultApi, "/local_schedulers/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a local scheduler.
Retrieve a local scheduler.
Params:
- id::Int64 (required)
Return: LocalSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function get_local_scheduler(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_local_scheduler(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_local_scheduler(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_local_scheduler(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_pending_actions_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Vector{WorkflowActionModel},
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_pending_actions(_api::DefaultApi, id::Int64; trigger_type=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_pending_actions_DefaultApi, "/workflows/{id}/actions/pending", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "trigger_type", trigger_type; style="form", is_explode=true) # type Vector{String}
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Get pending workflow actions, optionally filtered by trigger type.
Get pending (unexecuted) workflow actions for a workflow, optionally filtered by trigger type.
Params:
- id::Int64 (required)
- trigger_type::Vector{String}
Return: Vector{WorkflowActionModel}, OpenAPI.Clients.ApiResponse
"""
function get_pending_actions(_api::DefaultApi, id::Int64; trigger_type=nothing, _mediaType=nothing)
_ctx = _oacinternal_get_pending_actions(_api, id; trigger_type=trigger_type, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_pending_actions(_api::DefaultApi, response_stream::Channel, id::Int64; trigger_type=nothing, _mediaType=nothing)
_ctx = _oacinternal_get_pending_actions(_api, id; trigger_type=trigger_type, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_ready_job_requirements_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => GetReadyJobRequirementsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_ready_job_requirements(_api::DefaultApi, id::Int64; scheduler_config_id=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_ready_job_requirements_DefaultApi, "/workflows/{id}/ready_job_requirements", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "scheduler_config_id", scheduler_config_id; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Return the resource requirements for jobs with a status of ready.
Return the resource requirements for jobs with a status of ready.
Params:
- id::Int64 (required)
- scheduler_config_id::Int64
Return: GetReadyJobRequirementsResponse, OpenAPI.Clients.ApiResponse
"""
function get_ready_job_requirements(_api::DefaultApi, id::Int64; scheduler_config_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_get_ready_job_requirements(_api, id; scheduler_config_id=scheduler_config_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_ready_job_requirements(_api::DefaultApi, response_stream::Channel, id::Int64; scheduler_config_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_get_ready_job_requirements(_api, id; scheduler_config_id=scheduler_config_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_resource_requirements_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResourceRequirementsModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_resource_requirements(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_resource_requirements_DefaultApi, "/resource_requirements/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve one resource requirements record.
Retrieve one resource requirements record.
Params:
- id::Int64 (required)
Return: ResourceRequirementsModel, OpenAPI.Clients.ApiResponse
"""
function get_resource_requirements(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_resource_requirements(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_resource_requirements(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_resource_requirements(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_result_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResultModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_result(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_result_DefaultApi, "/results/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a job result.
Retrieve a job result.
Params:
- id::Int64 (required)
Return: ResultModel, OpenAPI.Clients.ApiResponse
"""
function get_result(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_result(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_result(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_result(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_ro_crate_entity_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => RoCrateEntityModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_ro_crate_entity(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_ro_crate_entity_DefaultApi, "/ro_crate_entities/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Get an RO-Crate entity by ID.
Get an RO-Crate entity by ID.
Params:
- id::Int64 (required)
Return: RoCrateEntityModel, OpenAPI.Clients.ApiResponse
"""
function get_ro_crate_entity(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_ro_crate_entity(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_ro_crate_entity(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_ro_crate_entity(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_scheduled_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ScheduledComputeNodesModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_scheduled_compute_node(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_scheduled_compute_node_DefaultApi, "/scheduled_compute_nodes/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a scheduled compute node.
Retrieve a scheduled compute node.
Params:
- id::Int64 (required)
Return: ScheduledComputeNodesModel, OpenAPI.Clients.ApiResponse
"""
function get_scheduled_compute_node(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_scheduled_compute_node(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_scheduled_compute_node(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_scheduled_compute_node(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_slurm_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => SlurmSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_slurm_scheduler(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_slurm_scheduler_DefaultApi, "/slurm_schedulers/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a Slurm compute node configuration.
Retrieve a Slurm compute node configuration.
Params:
- id::Int64 (required)
Return: SlurmSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function get_slurm_scheduler(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_slurm_scheduler(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_slurm_scheduler(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_slurm_scheduler(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_user_data_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => UserDataModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_user_data(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_user_data_DefaultApi, "/user_data/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a user data record.
Retrieve a user data record.
Params:
- id::Int64 (required)
Return: UserDataModel, OpenAPI.Clients.ApiResponse
"""
function get_user_data(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_user_data(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_user_data(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_user_data(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_version_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_version(_api::DefaultApi; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_version_DefaultApi, "/version", [])
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Return the version of the service.
Return the version of the service.
Params:
Return: Any, OpenAPI.Clients.ApiResponse
"""
function get_version(_api::DefaultApi; _mediaType=nothing)
_ctx = _oacinternal_get_version(_api; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_version(_api::DefaultApi, response_stream::Channel; _mediaType=nothing)
_ctx = _oacinternal_get_version(_api; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_workflow_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_workflow(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_workflow_DefaultApi, "/workflows/{id}", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a workflow.
Retrieve a workflow.
Params:
- id::Int64 (required)
Return: WorkflowModel, OpenAPI.Clients.ApiResponse
"""
function get_workflow(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_workflow(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_workflow(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_workflow(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_workflow_actions_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Vector{WorkflowActionModel},
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_workflow_actions(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_workflow_actions_DefaultApi, "/workflows/{id}/actions", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Get all workflow actions for a workflow.
Get all workflow actions for a workflow.
Params:
- id::Int64 (required)
Return: Vector{WorkflowActionModel}, OpenAPI.Clients.ApiResponse
"""
function get_workflow_actions(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_workflow_actions(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_workflow_actions(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_workflow_actions(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_get_workflow_status_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowStatusModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_get_workflow_status(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_get_workflow_status_DefaultApi, "/workflows/{id}/status", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Return the workflow status.
Return the workflow status.
Params:
- id::Int64 (required)
Return: WorkflowStatusModel, OpenAPI.Clients.ApiResponse
"""
function get_workflow_status(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_workflow_status(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function get_workflow_status(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_get_workflow_status(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_initialize_jobs_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_initialize_jobs(_api::DefaultApi, id::Int64; only_uninitialized=nothing, clear_ephemeral_user_data=nothing, body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_initialize_jobs_DefaultApi, "/workflows/{id}/initialize_jobs", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "only_uninitialized", only_uninitialized; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "clear_ephemeral_user_data", clear_ephemeral_user_data; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Initialize job relationships based on file and user_data relationships.
Initialize job relationships based on file and user_data relationships.
Params:
- id::Int64 (required)
- only_uninitialized::Bool
- clear_ephemeral_user_data::Bool
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function initialize_jobs(_api::DefaultApi, id::Int64; only_uninitialized=nothing, clear_ephemeral_user_data=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_initialize_jobs(_api, id; only_uninitialized=only_uninitialized, clear_ephemeral_user_data=clear_ephemeral_user_data, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function initialize_jobs(_api::DefaultApi, response_stream::Channel, id::Int64; only_uninitialized=nothing, clear_ephemeral_user_data=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_initialize_jobs(_api, id; only_uninitialized=only_uninitialized, clear_ephemeral_user_data=clear_ephemeral_user_data, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_is_workflow_complete_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => IsCompleteResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_is_workflow_complete(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_is_workflow_complete_DefaultApi, "/workflows/{id}/is_complete", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Return true if all jobs in the workflow are complete.
Return true if all jobs in the workflow are complete.
Params:
- id::Int64 (required)
Return: IsCompleteResponse, OpenAPI.Clients.ApiResponse
"""
function is_workflow_complete(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_is_workflow_complete(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function is_workflow_complete(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_is_workflow_complete(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_is_workflow_uninitialized_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => IsUninitializedResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_is_workflow_uninitialized(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_is_workflow_uninitialized_DefaultApi, "/workflows/{id}/is_uninitialized", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Return true if all jobs in the workflow are uninitialized or disabled.
Return true if all jobs in the workflow are uninitialized or disabled.
Params:
- id::Int64 (required)
Return: IsUninitializedResponse, OpenAPI.Clients.ApiResponse
"""
function is_workflow_uninitialized(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_is_workflow_uninitialized(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function is_workflow_uninitialized(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_is_workflow_uninitialized(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_access_groups_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListAccessGroupsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_access_groups(_api::DefaultApi; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_access_groups_DefaultApi, "/access_groups", [])
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List all access groups.
List all access groups.
Params:
- offset::Int64
- limit::Int64
Return: ListAccessGroupsResponse, OpenAPI.Clients.ApiResponse
"""
function list_access_groups(_api::DefaultApi; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_access_groups(_api; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_access_groups(_api::DefaultApi, response_stream::Channel; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_access_groups(_api; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_compute_nodes_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListComputeNodesResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_compute_nodes(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, hostname=nothing, is_active=nothing, scheduled_compute_node_id=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_compute_nodes_DefaultApi, "/compute_nodes", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "hostname", hostname; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "is_active", is_active; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "scheduled_compute_node_id", scheduled_compute_node_id; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all compute node records for one workflow.
Retrieve all compute node records for one workflow.
Params:
- workflow_id::Int64 (required)
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- hostname::String
- is_active::Bool
- scheduled_compute_node_id::Int64
Return: ListComputeNodesResponse, OpenAPI.Clients.ApiResponse
"""
function list_compute_nodes(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, hostname=nothing, is_active=nothing, scheduled_compute_node_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_compute_nodes(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, hostname=hostname, is_active=is_active, scheduled_compute_node_id=scheduled_compute_node_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_compute_nodes(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, hostname=nothing, is_active=nothing, scheduled_compute_node_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_compute_nodes(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, hostname=hostname, is_active=is_active, scheduled_compute_node_id=scheduled_compute_node_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_events_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListEventsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_events(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, category=nothing, after_timestamp=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_events_DefaultApi, "/events", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "category", category; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "after_timestamp", after_timestamp; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all events for one workflow.
Retrieve all events for one workflow.
Params:
- workflow_id::Int64 (required)
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- category::String
- after_timestamp::Int64
Return: ListEventsResponse, OpenAPI.Clients.ApiResponse
"""
function list_events(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, category=nothing, after_timestamp=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_events(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, category=category, after_timestamp=after_timestamp, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_events(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, category=nothing, after_timestamp=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_events(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, category=category, after_timestamp=after_timestamp, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_failure_handlers_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListFailureHandlersResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_failure_handlers(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_failure_handlers_DefaultApi, "/workflows/{id}/failure_handlers", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List failure handlers for a workflow.
List all failure handlers for a workflow.
Params:
- id::Int64 (required)
- offset::Int64
- limit::Int64
Return: ListFailureHandlersResponse, OpenAPI.Clients.ApiResponse
"""
function list_failure_handlers(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_failure_handlers(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_failure_handlers(_api::DefaultApi, response_stream::Channel, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_failure_handlers(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_files_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListFilesResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_files(_api::DefaultApi, workflow_id::Int64; produced_by_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, path=nothing, is_output=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_files_DefaultApi, "/files", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "produced_by_job_id", produced_by_job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "name", name; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "path", path; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "is_output", is_output; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all files for one workflow.
Retrieve all files for one workflow.
Params:
- workflow_id::Int64 (required)
- produced_by_job_id::Int64
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- name::String
- path::String
- is_output::Bool
Return: ListFilesResponse, OpenAPI.Clients.ApiResponse
"""
function list_files(_api::DefaultApi, workflow_id::Int64; produced_by_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, path=nothing, is_output=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_files(_api, workflow_id; produced_by_job_id=produced_by_job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, path=path, is_output=is_output, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_files(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; produced_by_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, path=nothing, is_output=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_files(_api, workflow_id; produced_by_job_id=produced_by_job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, path=path, is_output=is_output, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_group_members_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListUserGroupMembershipsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_group_members(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_group_members_DefaultApi, "/access_groups/{id}/members", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List members of an access group.
List members of an access group.
Params:
- id::Int64 (required)
- offset::Int64
- limit::Int64
Return: ListUserGroupMembershipsResponse, OpenAPI.Clients.ApiResponse
"""
function list_group_members(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_group_members(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_group_members(_api::DefaultApi, response_stream::Channel, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_group_members(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_job_dependencies_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListJobDependenciesResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_job_dependencies(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_job_dependencies_DefaultApi, "/workflows/{id}/job_dependencies", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve job blocking relationships for a workflow.
Retrieve all job blocking relationships for one workflow from the job_depends_on table.
Params:
- id::Int64 (required)
- offset::Int64
- limit::Int64
Return: ListJobDependenciesResponse, OpenAPI.Clients.ApiResponse
"""
function list_job_dependencies(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_job_dependencies(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_job_dependencies(_api::DefaultApi, response_stream::Channel, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_job_dependencies(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_job_file_relationships_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListJobFileRelationshipsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_job_file_relationships(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_job_file_relationships_DefaultApi, "/workflows/{id}/job_file_relationships", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve job-file relationships for a workflow.
Retrieve all job-file relationships for one workflow from the job_input_file and job_output_file tables.
Params:
- id::Int64 (required)
- offset::Int64
- limit::Int64
Return: ListJobFileRelationshipsResponse, OpenAPI.Clients.ApiResponse
"""
function list_job_file_relationships(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_job_file_relationships(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_job_file_relationships(_api::DefaultApi, response_stream::Channel, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_job_file_relationships(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_job_ids_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListJobIdsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_job_ids(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_job_ids_DefaultApi, "/workflows/{id}/job_ids", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all job IDs for one workflow.
Retrieve all job IDs for one workflow.
Params:
- id::Int64 (required)
Return: ListJobIdsResponse, OpenAPI.Clients.ApiResponse
"""
function list_job_ids(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_job_ids(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_job_ids(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_job_ids(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_job_user_data_relationships_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListJobUserDataRelationshipsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_job_user_data_relationships(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_job_user_data_relationships_DefaultApi, "/workflows/{id}/job_user_data_relationships", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve job-user_data relationships for a workflow.
Retrieve all job-user_data relationships for one workflow from the job_input_user_data and job_output_user_data tables.
Params:
- id::Int64 (required)
- offset::Int64
- limit::Int64
Return: ListJobUserDataRelationshipsResponse, OpenAPI.Clients.ApiResponse
"""
function list_job_user_data_relationships(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_job_user_data_relationships(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_job_user_data_relationships(_api::DefaultApi, response_stream::Channel, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_job_user_data_relationships(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_jobs_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListJobsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_jobs(_api::DefaultApi, workflow_id::Int64; status=nothing, needs_file_id=nothing, upstream_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, include_relationships=nothing, active_compute_node_id=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_jobs_DefaultApi, "/jobs", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "status", status; style="simple", is_explode=false) # type JobStatus
OpenAPI.Clients.set_param(_ctx.query, "needs_file_id", needs_file_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "upstream_job_id", upstream_job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "include_relationships", include_relationships; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "active_compute_node_id", active_compute_node_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all jobs for one workflow.
Retrieve all jobs for one workflow.
Params:
- workflow_id::Int64 (required)
- status::JobStatus
- needs_file_id::Int64
- upstream_job_id::Int64
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- include_relationships::Bool
- active_compute_node_id::Int64
Return: ListJobsResponse, OpenAPI.Clients.ApiResponse
"""
function list_jobs(_api::DefaultApi, workflow_id::Int64; status=nothing, needs_file_id=nothing, upstream_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, include_relationships=nothing, active_compute_node_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_jobs(_api, workflow_id; status=status, needs_file_id=needs_file_id, upstream_job_id=upstream_job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, include_relationships=include_relationships, active_compute_node_id=active_compute_node_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_jobs(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; status=nothing, needs_file_id=nothing, upstream_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, include_relationships=nothing, active_compute_node_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_jobs(_api, workflow_id; status=status, needs_file_id=needs_file_id, upstream_job_id=upstream_job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, include_relationships=include_relationships, active_compute_node_id=active_compute_node_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_local_schedulers_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListLocalSchedulersResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_local_schedulers(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, memory=nothing, num_cpus=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_local_schedulers_DefaultApi, "/local_schedulers", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "memory", memory; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "num_cpus", num_cpus; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve local schedulers for one workflow.
Retrieve local schedulers for one workflow.
Params:
- workflow_id::Int64 (required)
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- memory::String
- num_cpus::Int64
Return: ListLocalSchedulersResponse, OpenAPI.Clients.ApiResponse
"""
function list_local_schedulers(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, memory=nothing, num_cpus=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_local_schedulers(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, memory=memory, num_cpus=num_cpus, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_local_schedulers(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, memory=nothing, num_cpus=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_local_schedulers(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, memory=memory, num_cpus=num_cpus, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_missing_user_data_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListMissingUserDataResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_missing_user_data(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_missing_user_data_DefaultApi, "/workflows/{id}/missing_user_data", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List missing user data that should exist.
List missing user data that should exist.
Params:
- id::Int64 (required)
Return: ListMissingUserDataResponse, OpenAPI.Clients.ApiResponse
"""
function list_missing_user_data(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_missing_user_data(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_missing_user_data(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_missing_user_data(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_remote_workers_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Vector{RemoteWorkerModel},
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_remote_workers(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_remote_workers_DefaultApi, "/workflows/{id}/remote_workers", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List all remote workers for a workflow.
List all remote workers for a workflow.
Params:
- id::Int64 (required)
Return: Vector{RemoteWorkerModel}, OpenAPI.Clients.ApiResponse
"""
function list_remote_workers(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_remote_workers(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_remote_workers(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_remote_workers(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_required_existing_files_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListRequiredExistingFilesResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_required_existing_files(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_required_existing_files_DefaultApi, "/workflows/{id}/required_existing_files", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List files that must exist.
List files that must exist.
Params:
- id::Int64 (required)
Return: ListRequiredExistingFilesResponse, OpenAPI.Clients.ApiResponse
"""
function list_required_existing_files(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_required_existing_files(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_required_existing_files(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_required_existing_files(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_resource_requirements_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListResourceRequirementsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_resource_requirements(_api::DefaultApi, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, memory=nothing, num_cpus=nothing, num_gpus=nothing, num_nodes=nothing, runtime=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_resource_requirements_DefaultApi, "/resource_requirements", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "job_id", job_id; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "name", name; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "memory", memory; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "num_cpus", num_cpus; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "num_gpus", num_gpus; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "num_nodes", num_nodes; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "runtime", runtime; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all resource requirements records for one workflow.
Retrieve all resource requirements records for one workflow.
Params:
- workflow_id::Int64 (required)
- job_id::Int64
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- name::String
- memory::String
- num_cpus::Int64
- num_gpus::Int64
- num_nodes::Int64
- runtime::Int64
Return: ListResourceRequirementsResponse, OpenAPI.Clients.ApiResponse
"""
function list_resource_requirements(_api::DefaultApi, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, memory=nothing, num_cpus=nothing, num_gpus=nothing, num_nodes=nothing, runtime=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_resource_requirements(_api, workflow_id; job_id=job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, memory=memory, num_cpus=num_cpus, num_gpus=num_gpus, num_nodes=num_nodes, runtime=runtime, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_resource_requirements(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, memory=nothing, num_cpus=nothing, num_gpus=nothing, num_nodes=nothing, runtime=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_resource_requirements(_api, workflow_id; job_id=job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, memory=memory, num_cpus=num_cpus, num_gpus=num_gpus, num_nodes=num_nodes, runtime=runtime, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_results_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListResultsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_results(_api::DefaultApi, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, run_id=nothing, return_code=nothing, status=nothing, all_runs=nothing, compute_node_id=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_results_DefaultApi, "/results", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "job_id", job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "run_id", run_id; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "return_code", return_code; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "status", status; style="form", is_explode=true) # type JobStatus
OpenAPI.Clients.set_param(_ctx.query, "all_runs", all_runs; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "compute_node_id", compute_node_id; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all job results for one workflow.
Retrieve all job results for one workflow.
Params:
- workflow_id::Int64 (required)
- job_id::Int64
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- run_id::Int64
- return_code::Int64
- status::JobStatus
- all_runs::Bool
- compute_node_id::Int64
Return: ListResultsResponse, OpenAPI.Clients.ApiResponse
"""
function list_results(_api::DefaultApi, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, run_id=nothing, return_code=nothing, status=nothing, all_runs=nothing, compute_node_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_results(_api, workflow_id; job_id=job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, run_id=run_id, return_code=return_code, status=status, all_runs=all_runs, compute_node_id=compute_node_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_results(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, run_id=nothing, return_code=nothing, status=nothing, all_runs=nothing, compute_node_id=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_results(_api, workflow_id; job_id=job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, run_id=run_id, return_code=return_code, status=status, all_runs=all_runs, compute_node_id=compute_node_id, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_ro_crate_entities_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListRoCrateEntitiesResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_ro_crate_entities(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_ro_crate_entities_DefaultApi, "/workflows/{id}/ro_crate_entities", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List all RO-Crate entities for a workflow.
List all RO-Crate entities for a workflow.
Params:
- id::Int64 (required)
- offset::Int64
- limit::Int64
Return: ListRoCrateEntitiesResponse, OpenAPI.Clients.ApiResponse
"""
function list_ro_crate_entities(_api::DefaultApi, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_ro_crate_entities(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_ro_crate_entities(_api::DefaultApi, response_stream::Channel, id::Int64; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_ro_crate_entities(_api, id; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_scheduled_compute_nodes_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListScheduledComputeNodesResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_scheduled_compute_nodes(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, scheduler_id=nothing, scheduler_config_id=nothing, status=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_scheduled_compute_nodes_DefaultApi, "/scheduled_compute_nodes", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "scheduler_id", scheduler_id; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "scheduler_config_id", scheduler_config_id; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "status", status; style="form", is_explode=true) # type String
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve scheduled compute node records for one workflow.
Retrieve scheduled compute node records for one workflow.
Params:
- workflow_id::Int64 (required)
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- scheduler_id::String
- scheduler_config_id::String
- status::String
Return: ListScheduledComputeNodesResponse, OpenAPI.Clients.ApiResponse
"""
function list_scheduled_compute_nodes(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, scheduler_id=nothing, scheduler_config_id=nothing, status=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_scheduled_compute_nodes(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, scheduler_id=scheduler_id, scheduler_config_id=scheduler_config_id, status=status, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_scheduled_compute_nodes(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, scheduler_id=nothing, scheduler_config_id=nothing, status=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_scheduled_compute_nodes(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, scheduler_id=scheduler_id, scheduler_config_id=scheduler_config_id, status=status, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_slurm_schedulers_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListSlurmSchedulersResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_slurm_schedulers(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, account=nothing, gres=nothing, mem=nothing, nodes=nothing, partition=nothing, qos=nothing, tmp=nothing, walltime=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_slurm_schedulers_DefaultApi, "/slurm_schedulers", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "name", name; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "account", account; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "gres", gres; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "mem", mem; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "nodes", nodes; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "partition", partition; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "qos", qos; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "tmp", tmp; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "walltime", walltime; style="form", is_explode=true) # type String
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve a Slurm compute node configuration.
Retrieve a Slurm compute node configuration.
Params:
- workflow_id::Int64 (required)
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- name::String
- account::String
- gres::String
- mem::String
- nodes::Int64
- partition::String
- qos::String
- tmp::String
- walltime::String
Return: ListSlurmSchedulersResponse, OpenAPI.Clients.ApiResponse
"""
function list_slurm_schedulers(_api::DefaultApi, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, account=nothing, gres=nothing, mem=nothing, nodes=nothing, partition=nothing, qos=nothing, tmp=nothing, walltime=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_slurm_schedulers(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, account=account, gres=gres, mem=mem, nodes=nodes, partition=partition, qos=qos, tmp=tmp, walltime=walltime, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_slurm_schedulers(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, account=nothing, gres=nothing, mem=nothing, nodes=nothing, partition=nothing, qos=nothing, tmp=nothing, walltime=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_slurm_schedulers(_api, workflow_id; offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, account=account, gres=gres, mem=mem, nodes=nodes, partition=partition, qos=qos, tmp=tmp, walltime=walltime, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_slurm_stats_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListSlurmStatsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_slurm_stats(_api::DefaultApi, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_slurm_stats_DefaultApi, "/slurm_stats", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "job_id", job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List Slurm accounting stats.
Retrieve Slurm accounting stats for a workflow, optionally filtered by job.
Params:
- workflow_id::Int64 (required)
- job_id::Int64
- offset::Int64
- limit::Int64
Return: ListSlurmStatsResponse, OpenAPI.Clients.ApiResponse
"""
function list_slurm_stats(_api::DefaultApi, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_slurm_stats(_api, workflow_id; job_id=job_id, offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_slurm_stats(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; job_id=nothing, offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_slurm_stats(_api, workflow_id; job_id=job_id, offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_user_data_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListUserDataResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_user_data(_api::DefaultApi, workflow_id::Int64; consumer_job_id=nothing, producer_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, is_ephemeral=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_user_data_DefaultApi, "/user_data", [])
OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "consumer_job_id", consumer_job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "producer_job_id", producer_job_id; style="simple", is_explode=false) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "name", name; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "is_ephemeral", is_ephemeral; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all user data records for one workflow.
Retrieve all user data records for one workflow.
Params:
- workflow_id::Int64 (required)
- consumer_job_id::Int64
- producer_job_id::Int64
- offset::Int64
- limit::Int64
- sort_by::String
- reverse_sort::Bool
- name::String
- is_ephemeral::Bool
Return: ListUserDataResponse, OpenAPI.Clients.ApiResponse
"""
function list_user_data(_api::DefaultApi, workflow_id::Int64; consumer_job_id=nothing, producer_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, is_ephemeral=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_user_data(_api, workflow_id; consumer_job_id=consumer_job_id, producer_job_id=producer_job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, is_ephemeral=is_ephemeral, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_user_data(_api::DefaultApi, response_stream::Channel, workflow_id::Int64; consumer_job_id=nothing, producer_job_id=nothing, offset=nothing, limit=nothing, sort_by=nothing, reverse_sort=nothing, name=nothing, is_ephemeral=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_user_data(_api, workflow_id; consumer_job_id=consumer_job_id, producer_job_id=producer_job_id, offset=offset, limit=limit, sort_by=sort_by, reverse_sort=reverse_sort, name=name, is_ephemeral=is_ephemeral, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_user_groups_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListAccessGroupsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_user_groups(_api::DefaultApi, user_name::String; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_user_groups_DefaultApi, "/users/{user_name}/groups", [])
OpenAPI.Clients.set_param(_ctx.path, "user_name", user_name) # type String
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List groups a user belongs to.
List groups a user belongs to.
Params:
- user_name::String (required)
- offset::Int64
- limit::Int64
Return: ListAccessGroupsResponse, OpenAPI.Clients.ApiResponse
"""
function list_user_groups(_api::DefaultApi, user_name::String; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_user_groups(_api, user_name; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_user_groups(_api::DefaultApi, response_stream::Channel, user_name::String; offset=nothing, limit=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_user_groups(_api, user_name; offset=offset, limit=limit, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_workflow_groups_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListAccessGroupsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_workflow_groups(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_workflow_groups_DefaultApi, "/workflows/{id}/access_groups", [])
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""List access groups that have access to a workflow.
List access groups that have access to a workflow.
Params:
- id::Int64 (required)
Return: ListAccessGroupsResponse, OpenAPI.Clients.ApiResponse
"""
function list_workflow_groups(_api::DefaultApi, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_workflow_groups(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_workflow_groups(_api::DefaultApi, response_stream::Channel, id::Int64; _mediaType=nothing)
_ctx = _oacinternal_list_workflow_groups(_api, id; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_list_workflows_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ListWorkflowsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_list_workflows(_api::DefaultApi; offset=nothing, sort_by=nothing, reverse_sort=nothing, limit=nothing, name=nothing, user=nothing, description=nothing, is_archived=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_workflows_DefaultApi, "/workflows", [])
OpenAPI.Clients.set_param(_ctx.query, "offset", offset; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "sort_by", sort_by; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "reverse_sort", reverse_sort; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_param(_ctx.query, "limit", limit; style="form", is_explode=true) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "name", name; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "user", user; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "description", description; style="form", is_explode=true) # type String
OpenAPI.Clients.set_param(_ctx.query, "is_archived", is_archived; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Retrieve all workflows.
Retrieve all workflows.
Params:
- offset::Int64
- sort_by::String
- reverse_sort::Bool
- limit::Int64
- name::String
- user::String
- description::String
- is_archived::Bool
Return: ListWorkflowsResponse, OpenAPI.Clients.ApiResponse
"""
function list_workflows(_api::DefaultApi; offset=nothing, sort_by=nothing, reverse_sort=nothing, limit=nothing, name=nothing, user=nothing, description=nothing, is_archived=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_workflows(_api; offset=offset, sort_by=sort_by, reverse_sort=reverse_sort, limit=limit, name=name, user=user, description=description, is_archived=is_archived, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function list_workflows(_api::DefaultApi, response_stream::Channel; offset=nothing, sort_by=nothing, reverse_sort=nothing, limit=nothing, name=nothing, user=nothing, description=nothing, is_archived=nothing, _mediaType=nothing)
_ctx = _oacinternal_list_workflows(_api; offset=offset, sort_by=sort_by, reverse_sort=reverse_sort, limit=limit, name=name, user=user, description=description, is_archived=is_archived, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_manage_status_change_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_manage_status_change(_api::DefaultApi, id::Int64, status::JobStatus, run_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_manage_status_change_DefaultApi, "/jobs/{id}/manage_status_change/{status}/{run_id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "status", status) # type JobStatus
OpenAPI.Clients.set_param(_ctx.path, "run_id", run_id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Change the status of a job and manage side effects.
Change the status of a job and manage side effects.
Params:
- id::Int64 (required)
- status::JobStatus (required)
- run_id::Int64 (required)
- body::Any
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function manage_status_change(_api::DefaultApi, id::Int64, status::JobStatus, run_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_manage_status_change(_api, id, status, run_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function manage_status_change(_api::DefaultApi, response_stream::Channel, id::Int64, status::JobStatus, run_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_manage_status_change(_api, id, status, run_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_ping_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_ping(_api::DefaultApi; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_ping_DefaultApi, "/ping", [])
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
return _ctx
end
@doc raw"""Check if the service is running.
Check if the service is running.
Params:
Return: Any, OpenAPI.Clients.ApiResponse
"""
function ping(_api::DefaultApi; _mediaType=nothing)
_ctx = _oacinternal_ping(_api; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function ping(_api::DefaultApi, response_stream::Channel; _mediaType=nothing)
_ctx = _oacinternal_ping(_api; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_process_changed_job_inputs_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ProcessChangedJobInputsResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_process_changed_job_inputs(_api::DefaultApi, id::Int64; dry_run=nothing, body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_process_changed_job_inputs_DefaultApi, "/workflows/{id}/process_changed_job_inputs", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "dry_run", dry_run; style="simple", is_explode=false) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Check for changed job inputs and update status accordingly.
Check for changed job inputs and update status accordingly.
Params:
- id::Int64 (required)
- dry_run::Bool
- body::Any
Return: ProcessChangedJobInputsResponse, OpenAPI.Clients.ApiResponse
"""
function process_changed_job_inputs(_api::DefaultApi, id::Int64; dry_run=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_process_changed_job_inputs(_api, id; dry_run=dry_run, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function process_changed_job_inputs(_api::DefaultApi, response_stream::Channel, id::Int64; dry_run=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_process_changed_job_inputs(_api, id; dry_run=dry_run, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_remove_user_from_group_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_remove_user_from_group(_api::DefaultApi, id::Int64, user_name::String; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_remove_user_from_group_DefaultApi, "/access_groups/{id}/members/{user_name}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "user_name", user_name) # type String
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Remove a user from an access group.
Remove a user from an access group.
Params:
- id::Int64 (required)
- user_name::String (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function remove_user_from_group(_api::DefaultApi, id::Int64, user_name::String; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_remove_user_from_group(_api, id, user_name; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function remove_user_from_group(_api::DefaultApi, response_stream::Channel, id::Int64, user_name::String; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_remove_user_from_group(_api, id, user_name; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_remove_workflow_from_group_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_remove_workflow_from_group(_api::DefaultApi, id::Int64, group_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "DELETE", _returntypes_remove_workflow_from_group_DefaultApi, "/workflows/{id}/access_groups/{group_id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "group_id", group_id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Revoke an access group's access to a workflow.
Revoke an access group's access to a workflow.
Params:
- id::Int64 (required)
- group_id::Int64 (required)
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function remove_workflow_from_group(_api::DefaultApi, id::Int64, group_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_remove_workflow_from_group(_api, id, group_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function remove_workflow_from_group(_api::DefaultApi, response_stream::Channel, id::Int64, group_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_remove_workflow_from_group(_api, id, group_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_reset_job_status_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResetJobStatusResponse,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_reset_job_status(_api::DefaultApi, id::Int64; failed_only=nothing, body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_reset_job_status_DefaultApi, "/workflows/{id}/reset_job_status", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "failed_only", failed_only; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Reset status for jobs to uninitialized.
Reset status for jobs to uninitialized.
Params:
- id::Int64 (required)
- failed_only::Bool
- body::Any
Return: ResetJobStatusResponse, OpenAPI.Clients.ApiResponse
"""
function reset_job_status(_api::DefaultApi, id::Int64; failed_only=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_reset_job_status(_api, id; failed_only=failed_only, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function reset_job_status(_api::DefaultApi, response_stream::Channel, id::Int64; failed_only=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_reset_job_status(_api, id; failed_only=failed_only, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_reset_workflow_status_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => Any,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_reset_workflow_status(_api::DefaultApi, id::Int64; force=nothing, body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_reset_workflow_status_DefaultApi, "/workflows/{id}/reset_status", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.query, "force", force; style="form", is_explode=true) # type Bool
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Reset worklow status.
Reset workflow status.
Params:
- id::Int64 (required)
- force::Bool
- body::Any
Return: Any, OpenAPI.Clients.ApiResponse
"""
function reset_workflow_status(_api::DefaultApi, id::Int64; force=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_reset_workflow_status(_api, id; force=force, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function reset_workflow_status(_api::DefaultApi, response_stream::Channel, id::Int64; force=nothing, body=nothing, _mediaType=nothing)
_ctx = _oacinternal_reset_workflow_status(_api, id; force=force, body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_retry_job_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_retry_job(_api::DefaultApi, id::Int64, run_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_retry_job_DefaultApi, "/jobs/{id}/retry/{run_id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "run_id", run_id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Retry a failed job.
Retry a failed job by resetting it to ready status and incrementing attempt_id.
Params:
- id::Int64 (required)
- run_id::Int64 (required)
- body::Any
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function retry_job(_api::DefaultApi, id::Int64, run_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_retry_job(_api, id, run_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function retry_job(_api::DefaultApi, response_stream::Channel, id::Int64, run_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_retry_job(_api, id, run_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_start_job_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_start_job(_api::DefaultApi, id::Int64, run_id::Int64, compute_node_id::Int64; body=nothing, _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_start_job_DefaultApi, "/jobs/{id}/start_job/{run_id}/{compute_node_id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "run_id", run_id) # type Int64
OpenAPI.Clients.set_param(_ctx.path, "compute_node_id", compute_node_id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Start a job and manage side effects.
Start a job and manage side effects.
Params:
- id::Int64 (required)
- run_id::Int64 (required)
- compute_node_id::Int64 (required)
- body::Any
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function start_job(_api::DefaultApi, id::Int64, run_id::Int64, compute_node_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_start_job(_api, id, run_id, compute_node_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function start_job(_api::DefaultApi, response_stream::Channel, id::Int64, run_id::Int64, compute_node_id::Int64; body=nothing, _mediaType=nothing)
_ctx = _oacinternal_start_job(_api, id, run_id, compute_node_id; body=body, _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ComputeNodeModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_compute_node(_api::DefaultApi, id::Int64, body::ComputeNodeModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_compute_node_DefaultApi, "/compute_nodes/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a compute node.
Update a compute node.
Params:
- id::Int64 (required)
- body::ComputeNodeModel (required)
Return: ComputeNodeModel, OpenAPI.Clients.ApiResponse
"""
function update_compute_node(_api::DefaultApi, id::Int64, body::ComputeNodeModel; _mediaType=nothing)
_ctx = _oacinternal_update_compute_node(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_compute_node(_api::DefaultApi, response_stream::Channel, id::Int64, body::ComputeNodeModel; _mediaType=nothing)
_ctx = _oacinternal_update_compute_node(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_event_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => EventModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_event(_api::DefaultApi, id::Int64, body::EventModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_event_DefaultApi, "/events/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update an event.
Update an event.
Params:
- id::Int64 (required)
- body::EventModel (required)
Return: EventModel, OpenAPI.Clients.ApiResponse
"""
function update_event(_api::DefaultApi, id::Int64, body::EventModel; _mediaType=nothing)
_ctx = _oacinternal_update_event(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_event(_api::DefaultApi, response_stream::Channel, id::Int64, body::EventModel; _mediaType=nothing)
_ctx = _oacinternal_update_event(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_file_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => FileModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_file(_api::DefaultApi, id::Int64, body::FileModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_file_DefaultApi, "/files/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a file.
Update a file.
Params:
- id::Int64 (required)
- body::FileModel (required)
Return: FileModel, OpenAPI.Clients.ApiResponse
"""
function update_file(_api::DefaultApi, id::Int64, body::FileModel; _mediaType=nothing)
_ctx = _oacinternal_update_file(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_file(_api::DefaultApi, response_stream::Channel, id::Int64, body::FileModel; _mediaType=nothing)
_ctx = _oacinternal_update_file(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_job_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => JobModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_job(_api::DefaultApi, id::Int64, body::JobModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_job_DefaultApi, "/jobs/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a job.
Update a job.
Params:
- id::Int64 (required)
- body::JobModel (required)
Return: JobModel, OpenAPI.Clients.ApiResponse
"""
function update_job(_api::DefaultApi, id::Int64, body::JobModel; _mediaType=nothing)
_ctx = _oacinternal_update_job(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_job(_api::DefaultApi, response_stream::Channel, id::Int64, body::JobModel; _mediaType=nothing)
_ctx = _oacinternal_update_job(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_local_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => LocalSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_local_scheduler(_api::DefaultApi, id::Int64, body::LocalSchedulerModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_local_scheduler_DefaultApi, "/local_schedulers/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a local scheduler.
Update a local scheduler.
Params:
- id::Int64 (required)
- body::LocalSchedulerModel (required)
Return: LocalSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function update_local_scheduler(_api::DefaultApi, id::Int64, body::LocalSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_update_local_scheduler(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_local_scheduler(_api::DefaultApi, response_stream::Channel, id::Int64, body::LocalSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_update_local_scheduler(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_resource_requirements_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResourceRequirementsModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("422", "x"=>".") * "\$") => DefaultErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_resource_requirements(_api::DefaultApi, id::Int64, body::ResourceRequirementsModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_resource_requirements_DefaultApi, "/resource_requirements/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update one resource requirements record.
Update one resource requirements record.
Params:
- id::Int64 (required)
- body::ResourceRequirementsModel (required)
Return: ResourceRequirementsModel, OpenAPI.Clients.ApiResponse
"""
function update_resource_requirements(_api::DefaultApi, id::Int64, body::ResourceRequirementsModel; _mediaType=nothing)
_ctx = _oacinternal_update_resource_requirements(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_resource_requirements(_api::DefaultApi, response_stream::Channel, id::Int64, body::ResourceRequirementsModel; _mediaType=nothing)
_ctx = _oacinternal_update_resource_requirements(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_result_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ResultModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_result(_api::DefaultApi, id::Int64, body::ResultModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_result_DefaultApi, "/results/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a job result.
Update a job result.
Params:
- id::Int64 (required)
- body::ResultModel (required)
Return: ResultModel, OpenAPI.Clients.ApiResponse
"""
function update_result(_api::DefaultApi, id::Int64, body::ResultModel; _mediaType=nothing)
_ctx = _oacinternal_update_result(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_result(_api::DefaultApi, response_stream::Channel, id::Int64, body::ResultModel; _mediaType=nothing)
_ctx = _oacinternal_update_result(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_ro_crate_entity_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => RoCrateEntityModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_ro_crate_entity(_api::DefaultApi, id::Int64, body::RoCrateEntityModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_ro_crate_entity_DefaultApi, "/ro_crate_entities/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update an RO-Crate entity.
Update an RO-Crate entity.
Params:
- id::Int64 (required)
- body::RoCrateEntityModel (required)
Return: RoCrateEntityModel, OpenAPI.Clients.ApiResponse
"""
function update_ro_crate_entity(_api::DefaultApi, id::Int64, body::RoCrateEntityModel; _mediaType=nothing)
_ctx = _oacinternal_update_ro_crate_entity(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_ro_crate_entity(_api::DefaultApi, response_stream::Channel, id::Int64, body::RoCrateEntityModel; _mediaType=nothing)
_ctx = _oacinternal_update_ro_crate_entity(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_scheduled_compute_node_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => ScheduledComputeNodesModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_scheduled_compute_node(_api::DefaultApi, id::Int64, body::ScheduledComputeNodesModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_scheduled_compute_node_DefaultApi, "/scheduled_compute_nodes/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a scheduled compute node.
Update a scheduled compute node.
Params:
- id::Int64 (required)
- body::ScheduledComputeNodesModel (required)
Return: ScheduledComputeNodesModel, OpenAPI.Clients.ApiResponse
"""
function update_scheduled_compute_node(_api::DefaultApi, id::Int64, body::ScheduledComputeNodesModel; _mediaType=nothing)
_ctx = _oacinternal_update_scheduled_compute_node(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_scheduled_compute_node(_api::DefaultApi, response_stream::Channel, id::Int64, body::ScheduledComputeNodesModel; _mediaType=nothing)
_ctx = _oacinternal_update_scheduled_compute_node(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_slurm_scheduler_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => SlurmSchedulerModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_slurm_scheduler(_api::DefaultApi, id::Int64, body::SlurmSchedulerModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_slurm_scheduler_DefaultApi, "/slurm_schedulers/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a Slurm compute node configuration.
Update a Slurm compute node configuration.
Params:
- id::Int64 (required)
- body::SlurmSchedulerModel (required)
Return: SlurmSchedulerModel, OpenAPI.Clients.ApiResponse
"""
function update_slurm_scheduler(_api::DefaultApi, id::Int64, body::SlurmSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_update_slurm_scheduler(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_slurm_scheduler(_api::DefaultApi, response_stream::Channel, id::Int64, body::SlurmSchedulerModel; _mediaType=nothing)
_ctx = _oacinternal_update_slurm_scheduler(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_user_data_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => UserDataModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_user_data(_api::DefaultApi, id::Int64, body::UserDataModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_user_data_DefaultApi, "/user_data/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a user data record.
Update a user data record.
Params:
- id::Int64 (required)
- body::UserDataModel (required)
Return: UserDataModel, OpenAPI.Clients.ApiResponse
"""
function update_user_data(_api::DefaultApi, id::Int64, body::UserDataModel; _mediaType=nothing)
_ctx = _oacinternal_update_user_data(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_user_data(_api::DefaultApi, response_stream::Channel, id::Int64, body::UserDataModel; _mediaType=nothing)
_ctx = _oacinternal_update_user_data(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_workflow_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_workflow(_api::DefaultApi, id::Int64, body::WorkflowModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_workflow_DefaultApi, "/workflows/{id}", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update a workflow.
Update a workflow.
Params:
- id::Int64 (required)
- body::WorkflowModel (required)
Return: WorkflowModel, OpenAPI.Clients.ApiResponse
"""
function update_workflow(_api::DefaultApi, id::Int64, body::WorkflowModel; _mediaType=nothing)
_ctx = _oacinternal_update_workflow(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_workflow(_api::DefaultApi, response_stream::Channel, id::Int64, body::WorkflowModel; _mediaType=nothing)
_ctx = _oacinternal_update_workflow(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
const _returntypes_update_workflow_status_DefaultApi = Dict{Regex,Type}(
Regex("^" * replace("200", "x"=>".") * "\$") => WorkflowStatusModel,
Regex("^" * replace("403", "x"=>".") * "\$") => ForbiddenErrorResponse,
Regex("^" * replace("404", "x"=>".") * "\$") => NotFoundErrorResponse,
Regex("^" * replace("500", "x"=>".") * "\$") => DefaultErrorResponse,
)
function _oacinternal_update_workflow_status(_api::DefaultApi, id::Int64, body::WorkflowStatusModel; _mediaType=nothing)
_ctx = OpenAPI.Clients.Ctx(_api.client, "PUT", _returntypes_update_workflow_status_DefaultApi, "/workflows/{id}/status", [], body)
OpenAPI.Clients.set_param(_ctx.path, "id", id) # type Int64
OpenAPI.Clients.set_header_accept(_ctx, ["application/json", ])
OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? ["application/json", ] : [_mediaType])
return _ctx
end
@doc raw"""Update the workflow status.
Update the workflow status.
Params:
- id::Int64 (required)
- body::WorkflowStatusModel (required)
Return: WorkflowStatusModel, OpenAPI.Clients.ApiResponse
"""
function update_workflow_status(_api::DefaultApi, id::Int64, body::WorkflowStatusModel; _mediaType=nothing)
_ctx = _oacinternal_update_workflow_status(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx)
end
function update_workflow_status(_api::DefaultApi, response_stream::Channel, id::Int64, body::WorkflowStatusModel; _mediaType=nothing)
_ctx = _oacinternal_update_workflow_status(_api, id, body; _mediaType=_mediaType)
return OpenAPI.Clients.exec(_ctx, response_stream)
end
export add_user_to_group
export add_workflow_to_group
export cancel_workflow
export check_workflow_access
export claim_action
export claim_jobs_based_on_resources
export claim_next_jobs
export complete_job
export create_access_group
export create_compute_node
export create_event
export create_failure_handler
export create_file
export create_job
export create_jobs
export create_local_scheduler
export create_remote_workers
export create_resource_requirements
export create_result
export create_ro_crate_entity
export create_scheduled_compute_node
export create_slurm_scheduler
export create_slurm_stats
export create_user_data
export create_workflow
export create_workflow_action
export delete_access_group
export delete_all_user_data
export delete_compute_node
export delete_compute_nodes
export delete_event
export delete_events
export delete_failure_handler
export delete_file
export delete_files
export delete_job
export delete_jobs
export delete_local_scheduler
export delete_local_schedulers
export delete_remote_worker
export delete_resource_requirement
export delete_resource_requirements
export delete_result
export delete_results
export delete_ro_crate_entities
export delete_ro_crate_entity
export delete_scheduled_compute_node
export delete_scheduled_compute_nodes
export delete_slurm_scheduler
export delete_slurm_schedulers
export delete_user_data
export delete_workflow
export get_access_group
export get_compute_node
export get_event
export get_failure_handler
export get_file
export get_job
export get_latest_event_timestamp
export get_local_scheduler
export get_pending_actions
export get_ready_job_requirements
export get_resource_requirements
export get_result
export get_ro_crate_entity
export get_scheduled_compute_node
export get_slurm_scheduler
export get_user_data
export get_version
export get_workflow
export get_workflow_actions
export get_workflow_status
export initialize_jobs
export is_workflow_complete
export is_workflow_uninitialized
export list_access_groups
export list_compute_nodes
export list_events
export list_failure_handlers
export list_files
export list_group_members
export list_job_dependencies
export list_job_file_relationships
export list_job_ids
export list_job_user_data_relationships
export list_jobs
export list_local_schedulers
export list_missing_user_data
export list_remote_workers
export list_required_existing_files
export list_resource_requirements
export list_results
export list_ro_crate_entities
export list_scheduled_compute_nodes
export list_slurm_schedulers
export list_slurm_stats
export list_user_data
export list_user_groups
export list_workflow_groups
export list_workflows
export manage_status_change
export ping
export process_changed_job_inputs
export remove_user_from_group
export remove_workflow_from_group
export reset_job_status
export reset_workflow_status
export retry_job
export start_job
export update_compute_node
export update_event
export update_file
export update_job
export update_local_scheduler
export update_resource_requirements
export update_result
export update_ro_crate_entity
export update_scheduled_compute_node
export update_slurm_scheduler
export update_user_data
export update_workflow
export update_workflow_status