MCPcopy Create free account

hub / github.com/couler-proj/couler / functions

Functions605 in github.com/couler-proj/couler

↓ 1 callersMethodGetSuccessCondition
()
go/couler/proto/couler/v1/couler.pb.go:616
↓ 1 callersMethodGetTemplates
()
go/couler/proto/couler/v1/couler.pb.go:992
↓ 1 callersMethodGetVolumeMounts
()
go/couler/proto/couler/v1/couler.pb.go:566
↓ 1 callersFunctionNew
New returns ArgoWorkflowSubmitter struct
go/couler/submitter/argo_submitter.go:22
↓ 1 callersMethodString
()
go/couler/proto/couler/v1/couler.pb.go:727
↓ 1 callersMethod__init__
( self, name, template=None, arguments=None, when=None, with_items=None )
couler/core/templates/step.py:21
↓ 1 callersFunction_add_env_to_step
(pb_step, env)
couler/core/proto_repr.py:183
↓ 1 callersFunction_add_io_to_template
( pb_tmpl, source_step_id, input=None, output=None, script_output=None )
couler/core/proto_repr.py:205
↓ 1 callersFunction_cleanup
Cleanup the cached fields, just used for unit test.
couler/core/states.py:91
↓ 1 callersFunction_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 callersMethod_convert_args_to_input_parameters
(self, args)
couler/core/templates/container.py:193
↓ 1 callersMethod_create_workflow
(self, workflow_yaml)
couler/argo_submitter.py:153
↓ 1 callersFunction_get_uuid
use uuid4 to gen ascii uuid, length=8
couler/core/utils.py:267
↓ 1 callersFunction_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 callersFunction_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 callersFunction_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 callersFunction_validate_objective
(objective)
couler/steps/katib.py:106
↓ 1 callersFunction_validate_pod_params
(pod_type, allowed_pod_types, image=None, replicas=0)
couler/steps/pod_utils.py:19
↓ 1 callersFunction_validate_tuning_params
(tuning_params)
couler/steps/katib.py:117
↓ 1 callersMethodadd_pvc_template
(self, pvc: VolumeClaimTemplate)
couler/core/templates/workflow.py:61
↓ 1 callersMethodcheck_name
Check the name is valid or not
couler/argo_submitter.py:96
↓ 1 callersMethodcleanup
(self)
couler/core/templates/workflow.py:281
↓ 1 callersFunctioncleanup_proto_workflow
()
couler/core/proto_repr.py:32
↓ 1 callersFunctionconditional_child
()
integration_tests/dag_example.py:62
↓ 1 callersFunctionconditional_parent
()
integration_tests/dag_example.py:56
↓ 1 callersMethodconfig_cron_workflow
(self, cron_config)
couler/core/templates/workflow.py:273
↓ 1 callersFunctionconsume_m
(*other)
couler/tests/map_test.py:26
↓ 1 callersMethodcontainer_dict
(self)
couler/core/templates/container.py:155
↓ 1 callersFunctioncreateDAGTasks
(workflowPb *pb.Workflow, entryPointName string)
go/couler/conversion/argo_workflow.go:64
↓ 1 callersFunctioncreateExitHandlerSteps
(workflowPb *pb.Workflow, templates []wfv1.Template, exitHandlerTemplateName string)
go/couler/conversion/argo_workflow.go:100
↓ 1 callersFunctioncreateSeqOrParallelSteps
(workflowPb *pb.Workflow, entryPointName string)
go/couler/conversion/argo_workflow.go:85
↓ 1 callersFunctioncreate_secret
Store the input dict as a secret in k8s, and return the secret name.
couler/argo.py:262
↓ 1 callersFunctionfail_step
(name)
integration_tests/dag_depends_example.py:25
↓ 1 callersFunctionflip_coin
()
integration_tests/flip_coin_example.py:31
↓ 1 callersFunctionflip_coin
()
integration_tests/flip_coin_security_context_example.py:31
↓ 1 callersFunctionflip_coin
()
couler/tests/dag_test.py:66
↓ 1 callersFunctionflip_coin
()
examples/coin_flip.py:12
↓ 1 callersFunctiongenerate_number
()
couler/tests/input_parameter_test.py:29
↓ 1 callersFunctiongetInputsAndOutputsFromTemplate
(template *pb.StepTemplate)
go/couler/conversion/argo_workflow.go:219
↓ 1 callersMethodget_core_api_client
(self)
couler/argo_submitter.py:118
↓ 1 callersMethodget_options_to_dict
(self)
couler/core/templates/dns.py:35
↓ 1 callersMethodget_step
(self, name)
couler/core/templates/workflow.py:85
↓ 1 callersFunctionget_uniq_step_id
()
couler/core/proto_repr.py:39
↓ 1 callersMethodget_volume_mounts
(self)
couler/core/templates/container.py:77
↓ 1 callersMethodhas_pvc_template
(self, name)
couler/core/templates/workflow.py:64
↓ 1 callersMethodhas_volume
(self, name)
couler/core/templates/workflow.py:73
↓ 1 callersFunctionheads
()
integration_tests/flip_coin_example.py:35
↓ 1 callersFunctionheads
()
integration_tests/flip_coin_security_context_example.py:35
↓ 1 callersFunctionheads
()
examples/coin_flip.py:16
↓ 1 callersFunctioninput_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 callersFunctionjob
(name)
examples/node_assign.py:5
↓ 1 callersFunctionlinear
()
integration_tests/dag_example.py:75
↓ 1 callersFunctionlinear
()
examples/dag.py:19
↓ 1 callersMethodmock_dict
(x, mock_str="pytest")
couler/tests/argo_yaml_test.py:29
↓ 1 callersFunctionparse_argo_output
(output, prefix)
couler/core/templates/output.py:80
↓ 1 callersMethodresource_dict
(self)
couler/core/templates/job.py:76
↓ 1 callersMethodrun_a_container
(self)
couler/tests/env_test.py:25
↓ 1 callersMethodrun_a_gpu_container
(self)
couler/tests/env_test.py:37
↓ 1 callersMethodrun_a_gpu_script
(self)
couler/tests/env_test.py:45
↓ 1 callersMethodrun_a_script
(self)
couler/tests/env_test.py:32
↓ 1 callersFunctionrun_dag
Create a DAG to submit to Argo Workflows
examples/depends.py:48
↓ 1 callersMethodscript_dict
(self)
couler/core/templates/script.py:93
↓ 1 callersFunctionsimple
()
examples/node_assign.py:22
↓ 1 callersFunctionstart_pod
(message)
couler/tests/workflow_validation_utils_test.py:21
↓ 1 callersFunctionstart_pod_with_step
(message, step_name)
couler/tests/workflow_validation_utils_test.py:29
↓ 1 callersFunctionstepSecretToEnvs
(step *pb.Step)
go/couler/conversion/argo_workflow.go:113
↓ 1 callersFunctiontails
()
integration_tests/flip_coin_example.py:41
↓ 1 callersFunctiontails
()
integration_tests/flip_coin_security_context_example.py:41
↓ 1 callersFunctiontails
()
examples/coin_flip.py:22
↓ 1 callersMethodto_dict
(self)
couler/core/templates/toleration.py:23
↓ 1 callersMethodto_dict
(self)
couler/core/templates/dns.py:25
↓ 1 callersMethodto_dict
(self)
couler/core/templates/volume_claim.py:25
↓ 1 callersMethodto_dict
(self)
couler/core/templates/container.py:80
↓ 1 callersMethodto_dict
(self)
couler/core/templates/volume.py:22
↓ 1 callersMethodupdate_dag_task
(self, name, task)
couler/core/templates/workflow.py:108
↓ 1 callersFunctionvalidate_workflow_yaml
(original_wf)
couler/core/workflow_validation_utils.py:31
↓ 1 callersFunctionworkflow_filename
Return the Python file that defines the workflow.
couler/core/utils.py:92
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:39
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:94
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:158
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:260
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:305
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:411
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:459
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:516
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:587
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:657
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:852
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:893
MethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:956
MethodGetAccessKey
()
go/couler/proto/couler/v1/couler.pb.go:215
MethodGetArgs
()
go/couler/proto/couler/v1/couler.pb.go:686
MethodGetArtifact
()
go/couler/proto/couler/v1/couler.pb.go:377
MethodGetAttrs
()
go/couler/proto/couler/v1/couler.pb.go:821
MethodGetAttrs
()
go/couler/proto/couler/v1/couler.pb.go:1020
MethodGetBucket
()
go/couler/proto/couler/v1/couler.pb.go:236
MethodGetCannedStepSpec
()
go/couler/proto/couler/v1/couler.pb.go:786
MethodGetEndpoint
()
go/couler/proto/couler/v1/couler.pb.go:229
MethodGetGlobalName
()
go/couler/proto/couler/v1/couler.pb.go:75
MethodGetId
()
go/couler/proto/couler/v1/couler.pb.go:751
← previousnext →101–200 of 605, ranked by callers