MCPcopy Create free account

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

Functions605 in github.com/couler-proj/couler

Methodconsumer
(inputs)
couler/tests/artifact_test.py:167
Methodconsumer
(inputs)
couler/tests/argo_test.py:253
Functionconvert_dict_to_env_list
This is to convert a Python dictionary to a list, where each list item is a dict with `name` and `value` keys.
couler/core/utils.py:200
Functioncreate_local_artifact
(path, is_global=False)
couler/argo.py:178
Functioncreate_oss_artifact
Configure the object as OssArtifact OSS configuration can be found (https://www.alibabacloud.com/help/doc-detail/32027.htm) :param pa
couler/argo.py:182
Functioncreate_parameter_artifact
(path, is_global=False)
couler/argo.py:174
Functioncreate_s3_artifact
Configure the object as S3Artifact :param path: the local path of container :param bucket: s3 bucket :param accesskey_id: s3 user id
couler/argo.py:214
Functioncreate_workflow_volume
Create a transient volume for use in the workflow. Reference: https://github.com/argoproj/argo/blob/master/examples/volumes-pvc.yaml
couler/core/syntax/volume.py:29
Functiondag
Generate a DAG of Argo YAML Note: couler.set_dependencies() is more preferable. https://github.com/argoproj/argo/blob/master/examples/dag
couler/core/syntax/dag.py:19
Functiondefault_workflow_name_salter
(name)
couler/core/states.py:31
Functiondelete
( name, namespace="default", config_file=None, context=None, client_configuration=None,
couler/argo.py:101
Functiondiamond
()
integration_tests/dag_example.py:87
Functiondiamond
()
examples/dag.py:31
Methodecho
()
couler/tests/proto_repr_test.py:31
Functionencode_base64
Encode a string using base64 and return a binary string. This function is used in Secret creation. For example, the secrets for Argo YAML
couler/core/utils.py:137
Functionequal
(pre, post=None)
couler/core/syntax/predicates.py:35
Functionexec_while
Generate the Argo recursive logic. For example https://github.com/argoproj/argo/blob/master/examples/README.md#recursion.
couler/core/syntax/recursion.py:20
Functionexit_handler_failed
()
integration_tests/dag_example.py:41
Methodexit_handler_failed
()
couler/tests/argo_test.py:378
Functionexit_handler_succeeded
()
integration_tests/dag_example.py:33
Methodexit_handler_succeeded
()
couler/tests/argo_test.py:371
Functionextract_step_return
Extract information for run container or script output. step_output is a list with multiple outputs
couler/core/templates/output.py:212
Methodfinalize_options
Post-process options.
setup.py:29
Functiongenerate_parameters_run_job
Generate the inputs parameter for running kubernetes resource
couler/core/utils.py:148
Methodget_cluster_config_name
(self)
couler/core/templates/workflow.py:111
Methodget_custom_object_api_client
(self)
couler/argo_submitter.py:115
Functionget_secret
Get secret by name.
couler/core/states.py:86
Functionget_step_output
(step_name)
couler/core/states.py:81
Functiongpu_requested
Check whether the requested resources contains GPU. Here resources is a dict like {"cpu": 1, "memory": 2,...}.
couler/core/utils.py:245
Methodheads
()
couler/tests/proto_repr_test.py:65
Functioninit
()
go/couler/proto/couler/v1/couler.pb.go:1027
Functioninit_yaml_dump
()
couler/argo.py:141
Methodinitialize_options
Set default values for options.
setup.py:25
Methodinner_func
()
couler/tests/utils_test.py:47
Functioninvocation_location
If a function A in file B calls function C, which in turn calls invocation_location(), the call returns information about the invocation, in p
couler/core/utils.py:47
Functioninvocation_name
Argo YAML requires that each step, which is an invocation to a template, has a name. For example, hello1, hello2a, and hello2b in https://git
couler/core/utils.py:112
MethodisStepIO_StepIo
()
go/couler/proto/couler/v1/couler.pb.go:342
MethodisStepIO_StepIo
()
go/couler/proto/couler/v1/couler.pb.go:357
MethodisStepIO_StepIo
()
go/couler/proto/couler/v1/couler.pb.go:359
MethodisStepIO_StepIo
()
go/couler/proto/couler/v1/couler.pb.go:361
Methodjob_1
()
couler/tests/secret_test.py:83
Methodjob_2
()
couler/tests/secret_test.py:90
Methodjob_exit
()
couler/tests/dag_test.py:223
Methodjob_one
()
couler/tests/run_concurrent_test.py:93
Methodjob_two
()
couler/tests/run_concurrent_test.py:103
Functionload_cluster_config
Load user provided cluster specification file.
couler/core/utils.py:123
Functionmain
()
go/couler/commands/submit.go:58
Functionmake_list_if_not
(item)
couler/core/utils.py:239
Functionmap
map operation of Couler
couler/core/syntax/loop.py:22
Functionnon_empty
Check whether the `collection` is none or empty.
couler/core/utils.py:260
Functionnot_equal
(pre, post=None)
couler/core/syntax/predicates.py:42
Functionobtain_secret
Get the key from secret in k8s, and return the secret name.
couler/argo.py:247
Methodoutput_message
(message)
couler/tests/workflow_basic_test.py:184
Methodproducer
()
couler/tests/artifact_test.py:148
Methodproducer
()
couler/tests/argo_test.py:240
Methodproducer_two
()
couler/tests/step_output_test.py:45
Methodproducer_two
(step_name)
couler/tests/dag_test.py:147
Functionrandom_code
()
integration_tests/flip_coin_example.py:24
Functionrandom_code
()
integration_tests/dag_example.py:49
Functionrandom_code
()
integration_tests/flip_coin_security_context_example.py:24
Functionrandom_code
()
couler/tests/dag_test.py:59
Functionrandom_code
()
couler/tests/workflow_basic_test.py:24
Functionrandom_code
()
couler/tests/input_parameter_test.py:22
Functionrandom_code
()
couler/tests/while_test.py:18
Functionrandom_code
()
examples/coin_flip.py:5
Functionrandom_code
Randomly generate a 'success' or 'fail' to let sys.exit emulate a task final state
examples/depends.py:15
Methodrandom_code
()
couler/tests/proto_repr_test.py:59
Functionrepr_str
(dumper, data)
couler/argo.py:144
Functionrun
To submit the workflow using user-provided submitter implementation. Note that, the provided submitter must have a submit function which
couler/argo.py:56
Functionrun
Args: tuning_params: A dictionary of hyperparameters to be tuned. objective: The dictionary of objective for model training.
couler/steps/katib.py:43
Functionrun_canned_step
( name, args, inputs=None, outputs=None, step_name=None, cache=None )
couler/core/run_templates.py:456
Functionrun_container
Generate an Argo container template. For example, the template whalesay in https://github.com/argoproj/argo/tree/master/examples#hello-world
couler/core/run_templates.py:197
Methodrun_docker_container
(image, command)
couler/docker_submitter.py:21
Functionrun_job
Create a k8s job. For example, the pi-tmpl template in https://github.com/argoproj/argo/blob/master/examples/k8s-jobs.yaml :param manifes
couler/core/run_templates.py:354
Functionrun_multiple_pods
(num_pods)
couler/tests/workflow_validation_utils_test.py:38
Functionrun_script
Generate an Argo script template. For example, https://github.com/argoproj/argo/tree/master/examples#scripts--results. :param image: Doc
couler/core/run_templates.py:41
Methodsend_mail
()
couler/tests/proto_repr_test.py:87
MethodsetUp
(self)
couler/tests/artifact_test.py:22
MethodsetUp
(self)
couler/tests/env_test.py:21
MethodsetUp
(self)
couler/tests/daemon_step_test.py:19
MethodsetUp
(self)
couler/tests/argo_test.py:29
MethodsetUp
(self)
couler/tests/argo_test.py:57
Functionset_default_submitter
Config couler defaults. :param submitter: default submitter to use when submitting workflows :return:
couler/argo.py:89
Functionset_dependencies
:param step_function: step to run :param dependencies: the list of dependencies of this step. This can be in either of the following
couler/core/syntax/dag.py:44
Functionset_dns
Set dns policy and config to the workflow. https://argoproj.github.io/argo-workflows/fields/#poddnsconfig
couler/core/syntax/dns.py:18
Functionset_exit_handler
Configure the workflow handler Status would be: Succeeded, Failed, or Error. Each status invokes one exit_handler function. https://g
couler/core/syntax/exit_handler.py:19
Functionsmaller
(pre, post=None)
couler/core/syntax/predicates.py:56
Functionsmaller_equal
(pre, post=None)
couler/core/syntax/predicates.py:70
Methodsome_raise
()
couler/tests/dag_test.py:210
Functionstep_repr
( step_name=None, tmpl_name=None, image=None, command=None, source=None, env=None,
couler/core/proto_repr.py:45
Methodsummary
(messages)
couler/tests/run_concurrent_test.py:113
Methodtails
()
couler/tests/proto_repr_test.py:70
Methodtails
()
couler/tests/cron_workflow_test.py:22
MethodtearDown
(self)
couler/tests/artifact_test.py:25
MethodtearDown
(self)
couler/tests/proto_repr_test.py:27
MethodtearDown
(self)
couler/tests/daemon_step_test.py:22
MethodtearDown
(self)
couler/tests/argo_test.py:42
Methodtest_argo_safe_name
(self)
couler/tests/utils_test.py:21
Methodtest_artifact_passing
(self)
couler/tests/artifact_test.py:147
Methodtest_artifact_passing_script
(self)
couler/tests/argo_test.py:239
← previousnext →401–500 of 605, ranked by callers