Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/couler-proj/couler
/ functions
Functions
605 in github.com/couler-proj/couler
⨍
Functions
605
◇
Types & classes
85
↓ 1 callers
Method
GetSuccessCondition
()
go/couler/proto/couler/v1/couler.pb.go:616
↓ 1 callers
Method
GetTemplates
()
go/couler/proto/couler/v1/couler.pb.go:992
↓ 1 callers
Method
GetVolumeMounts
()
go/couler/proto/couler/v1/couler.pb.go:566
↓ 1 callers
Function
New
New returns ArgoWorkflowSubmitter struct
go/couler/submitter/argo_submitter.go:22
↓ 1 callers
Method
String
()
go/couler/proto/couler/v1/couler.pb.go:727
↓ 1 callers
Method
__init__
( self, name, template=None, arguments=None, when=None, with_items=None )
couler/core/templates/step.py:21
↓ 1 callers
Function
_add_env_to_step
(pb_step, env)
couler/core/proto_repr.py:183
↓ 1 callers
Function
_add_io_to_template
( pb_tmpl, source_step_id, input=None, output=None, script_output=None )
couler/core/proto_repr.py:205
↓ 1 callers
Function
_cleanup
Cleanup the cached fields, just used for unit test.
couler/core/states.py:91
↓ 1 callers
Function
_config_cron_workflow
Config the CronWorkflow, see example https://github.com/argoproj/argo/blob/master/docs/cron-workflows.md
couler/core/config.py:110
↓ 1 callers
Method
_convert_args_to_input_parameters
(self, args)
couler/core/templates/container.py:193
↓ 1 callers
Method
_create_workflow
(self, workflow_yaml)
couler/argo_submitter.py:153
↓ 1 callers
Function
_get_uuid
use uuid4 to gen ascii uuid, length=8
couler/core/utils.py:267
↓ 1 callers
Function
_job_output
:param step_name: :param template_name: https://github.com/argoproj/argo/blob/master/examples/k8s-jobs.yaml#L44 Return the job name a
couler/core/templates/output.py:185
↓ 1 callers
Function
_script_output
Generate output name from an Argo script template. For example, "{{steps.generate.outputs.result}}" in https://github.com/argoproj/argo/tree/
couler/core/templates/output.py:166
↓ 1 callers
Function
_update_dag_tasks
A task in DAG of Argo YAML contains name, related template and parameters. Here we insert a single task into the global tasks.
couler/core/step_update_utils.py:46
↓ 1 callers
Function
_validate_objective
(objective)
couler/steps/katib.py:106
↓ 1 callers
Function
_validate_pod_params
(pod_type, allowed_pod_types, image=None, replicas=0)
couler/steps/pod_utils.py:19
↓ 1 callers
Function
_validate_tuning_params
(tuning_params)
couler/steps/katib.py:117
↓ 1 callers
Method
add_pvc_template
(self, pvc: VolumeClaimTemplate)
couler/core/templates/workflow.py:61
↓ 1 callers
Method
check_name
Check the name is valid or not
couler/argo_submitter.py:96
↓ 1 callers
Method
cleanup
(self)
couler/core/templates/workflow.py:281
↓ 1 callers
Function
cleanup_proto_workflow
()
couler/core/proto_repr.py:32
↓ 1 callers
Function
conditional_child
()
integration_tests/dag_example.py:62
↓ 1 callers
Function
conditional_parent
()
integration_tests/dag_example.py:56
↓ 1 callers
Method
config_cron_workflow
(self, cron_config)
couler/core/templates/workflow.py:273
↓ 1 callers
Function
consume_m
(*other)
couler/tests/map_test.py:26
↓ 1 callers
Method
container_dict
(self)
couler/core/templates/container.py:155
↓ 1 callers
Function
createDAGTasks
(workflowPb *pb.Workflow, entryPointName string)
go/couler/conversion/argo_workflow.go:64
↓ 1 callers
Function
createExitHandlerSteps
(workflowPb *pb.Workflow, templates []wfv1.Template, exitHandlerTemplateName string)
go/couler/conversion/argo_workflow.go:100
↓ 1 callers
Function
createSeqOrParallelSteps
(workflowPb *pb.Workflow, entryPointName string)
go/couler/conversion/argo_workflow.go:85
↓ 1 callers
Function
create_secret
Store the input dict as a secret in k8s, and return the secret name.
couler/argo.py:262
↓ 1 callers
Function
fail_step
(name)
integration_tests/dag_depends_example.py:25
↓ 1 callers
Function
flip_coin
()
integration_tests/flip_coin_example.py:31
↓ 1 callers
Function
flip_coin
()
integration_tests/flip_coin_security_context_example.py:31
↓ 1 callers
Function
flip_coin
()
couler/tests/dag_test.py:66
↓ 1 callers
Function
flip_coin
()
examples/coin_flip.py:12
↓ 1 callers
Function
generate_number
()
couler/tests/input_parameter_test.py:29
↓ 1 callers
Function
getInputsAndOutputsFromTemplate
(template *pb.StepTemplate)
go/couler/conversion/argo_workflow.go:219
↓ 1 callers
Method
get_core_api_client
(self)
couler/argo_submitter.py:118
↓ 1 callers
Method
get_options_to_dict
(self)
couler/core/templates/dns.py:35
↓ 1 callers
Method
get_step
(self, name)
couler/core/templates/workflow.py:85
↓ 1 callers
Function
get_uniq_step_id
()
couler/core/proto_repr.py:39
↓ 1 callers
Method
get_volume_mounts
(self)
couler/core/templates/container.py:77
↓ 1 callers
Method
has_pvc_template
(self, name)
couler/core/templates/workflow.py:64
↓ 1 callers
Method
has_volume
(self, name)
couler/core/templates/workflow.py:73
↓ 1 callers
Function
heads
()
integration_tests/flip_coin_example.py:35
↓ 1 callers
Function
heads
()
integration_tests/flip_coin_security_context_example.py:35
↓ 1 callers
Function
heads
()
examples/coin_flip.py:16
↓ 1 callers
Function
input_parameter_name
Generate parameter name for using as template input parameter names in Argo YAML. For example, the parameter name "message" in the container
couler/core/utils.py:103
↓ 1 callers
Function
job
(name)
examples/node_assign.py:5
↓ 1 callers
Function
linear
()
integration_tests/dag_example.py:75
↓ 1 callers
Function
linear
()
examples/dag.py:19
↓ 1 callers
Method
mock_dict
(x, mock_str="pytest")
couler/tests/argo_yaml_test.py:29
↓ 1 callers
Function
parse_argo_output
(output, prefix)
couler/core/templates/output.py:80
↓ 1 callers
Method
resource_dict
(self)
couler/core/templates/job.py:76
↓ 1 callers
Method
run_a_container
(self)
couler/tests/env_test.py:25
↓ 1 callers
Method
run_a_gpu_container
(self)
couler/tests/env_test.py:37
↓ 1 callers
Method
run_a_gpu_script
(self)
couler/tests/env_test.py:45
↓ 1 callers
Method
run_a_script
(self)
couler/tests/env_test.py:32
↓ 1 callers
Function
run_dag
Create a DAG to submit to Argo Workflows
examples/depends.py:48
↓ 1 callers
Method
script_dict
(self)
couler/core/templates/script.py:93
↓ 1 callers
Function
simple
()
examples/node_assign.py:22
↓ 1 callers
Function
start_pod
(message)
couler/tests/workflow_validation_utils_test.py:21
↓ 1 callers
Function
start_pod_with_step
(message, step_name)
couler/tests/workflow_validation_utils_test.py:29
↓ 1 callers
Function
stepSecretToEnvs
(step *pb.Step)
go/couler/conversion/argo_workflow.go:113
↓ 1 callers
Function
tails
()
integration_tests/flip_coin_example.py:41
↓ 1 callers
Function
tails
()
integration_tests/flip_coin_security_context_example.py:41
↓ 1 callers
Function
tails
()
examples/coin_flip.py:22
↓ 1 callers
Method
to_dict
(self)
couler/core/templates/toleration.py:23
↓ 1 callers
Method
to_dict
(self)
couler/core/templates/dns.py:25
↓ 1 callers
Method
to_dict
(self)
couler/core/templates/volume_claim.py:25
↓ 1 callers
Method
to_dict
(self)
couler/core/templates/container.py:80
↓ 1 callers
Method
to_dict
(self)
couler/core/templates/volume.py:22
↓ 1 callers
Method
update_dag_task
(self, name, task)
couler/core/templates/workflow.py:108
↓ 1 callers
Function
validate_workflow_yaml
(original_wf)
couler/core/workflow_validation_utils.py:31
↓ 1 callers
Function
workflow_filename
Return the Python file that defines the workflow.
couler/core/utils.py:92
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:39
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:94
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:158
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:260
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:305
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:411
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:459
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:516
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:587
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:657
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:852
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:893
Method
Descriptor
()
go/couler/proto/couler/v1/couler.pb.go:956
Method
GetAccessKey
()
go/couler/proto/couler/v1/couler.pb.go:215
Method
GetArgs
()
go/couler/proto/couler/v1/couler.pb.go:686
Method
GetArtifact
()
go/couler/proto/couler/v1/couler.pb.go:377
Method
GetAttrs
()
go/couler/proto/couler/v1/couler.pb.go:821
Method
GetAttrs
()
go/couler/proto/couler/v1/couler.pb.go:1020
Method
GetBucket
()
go/couler/proto/couler/v1/couler.pb.go:236
Method
GetCannedStepSpec
()
go/couler/proto/couler/v1/couler.pb.go:786
Method
GetEndpoint
()
go/couler/proto/couler/v1/couler.pb.go:229
Method
GetGlobalName
()
go/couler/proto/couler/v1/couler.pb.go:75
Method
GetId
()
go/couler/proto/couler/v1/couler.pb.go:751
← previous
next →
101–200 of 605, ranked by callers