torc 0.22.0

Workflow management system
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

# This file was generated by the Julia OpenAPI Code Generator
# Do not modify this file directly. Modify the OpenAPI specification instead.

struct SlurmStatsApi <: OpenAPI.APIClientImpl
    client::OpenAPI.Clients.Client
end

"""
The default API base path for APIs in `SlurmStatsApi`.
This can be used to construct the `OpenAPI.Clients.Client` instance.
"""
basepath(::Type{ SlurmStatsApi }) = "http://localhost/torc-service/v1"

const _returntypes_create_slurm_stats_SlurmStatsApi = Dict{Regex,Type}(
    Regex("^" * replace("200", "x"=>".") * "\$") => SlurmStatsModel,
    Regex("^" * replace("403", "x"=>".") * "\$") => ErrorResponse,
    Regex("^" * replace("404", "x"=>".") * "\$") => ErrorResponse,
    Regex("^" * replace("500", "x"=>".") * "\$") => ErrorResponse,
)

function _oacinternal_create_slurm_stats(_api::SlurmStatsApi, slurm_stats_model::SlurmStatsModel; _mediaType=nothing)
    _ctx = OpenAPI.Clients.Ctx(_api.client, "POST", _returntypes_create_slurm_stats_SlurmStatsApi, "/slurm_stats", [], slurm_stats_model)
    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"""Params:
- slurm_stats_model::SlurmStatsModel (required)

Return: SlurmStatsModel, OpenAPI.Clients.ApiResponse
"""
function create_slurm_stats(_api::SlurmStatsApi, slurm_stats_model::SlurmStatsModel; _mediaType=nothing)
    _ctx = _oacinternal_create_slurm_stats(_api, slurm_stats_model; _mediaType=_mediaType)
    return OpenAPI.Clients.exec(_ctx)
end

function create_slurm_stats(_api::SlurmStatsApi, response_stream::Channel, slurm_stats_model::SlurmStatsModel; _mediaType=nothing)
    _ctx = _oacinternal_create_slurm_stats(_api, slurm_stats_model; _mediaType=_mediaType)
    return OpenAPI.Clients.exec(_ctx, response_stream)
end

const _returntypes_list_slurm_stats_SlurmStatsApi = Dict{Regex,Type}(
    Regex("^" * replace("200", "x"=>".") * "\$") => ListSlurmStatsResponse,
    Regex("^" * replace("403", "x"=>".") * "\$") => ErrorResponse,
    Regex("^" * replace("404", "x"=>".") * "\$") => ErrorResponse,
    Regex("^" * replace("500", "x"=>".") * "\$") => ErrorResponse,
)

function _oacinternal_list_slurm_stats(_api::SlurmStatsApi, workflow_id::Int64; job_id=nothing, run_id=nothing, attempt_id=nothing, offset=nothing, limit=nothing, _mediaType=nothing)
    _ctx = OpenAPI.Clients.Ctx(_api.client, "GET", _returntypes_list_slurm_stats_SlurmStatsApi, "/slurm_stats", [])
    OpenAPI.Clients.set_param(_ctx.query, "workflow_id", workflow_id; style="form", is_explode=true)  # 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, "run_id", run_id; style="form", is_explode=true)  # type Int64
    OpenAPI.Clients.set_param(_ctx.query, "attempt_id", attempt_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_header_accept(_ctx, ["application/json", ])
    OpenAPI.Clients.set_header_content_type(_ctx, (_mediaType === nothing) ? [] : [_mediaType])
    return _ctx
end

@doc raw"""Params:
- workflow_id::Int64 (required)
- job_id::Int64
- run_id::Int64
- attempt_id::Int64
- offset::Int64
- limit::Int64

Return: ListSlurmStatsResponse, OpenAPI.Clients.ApiResponse
"""
function list_slurm_stats(_api::SlurmStatsApi, workflow_id::Int64; job_id=nothing, run_id=nothing, attempt_id=nothing, offset=nothing, limit=nothing, _mediaType=nothing)
    _ctx = _oacinternal_list_slurm_stats(_api, workflow_id; job_id=job_id, run_id=run_id, attempt_id=attempt_id, offset=offset, limit=limit, _mediaType=_mediaType)
    return OpenAPI.Clients.exec(_ctx)
end

function list_slurm_stats(_api::SlurmStatsApi, response_stream::Channel, workflow_id::Int64; job_id=nothing, run_id=nothing, attempt_id=nothing, offset=nothing, limit=nothing, _mediaType=nothing)
    _ctx = _oacinternal_list_slurm_stats(_api, workflow_id; job_id=job_id, run_id=run_id, attempt_id=attempt_id, offset=offset, limit=limit, _mediaType=_mediaType)
    return OpenAPI.Clients.exec(_ctx, response_stream)
end

export create_slurm_stats
export list_slurm_stats