MCPcopy Create free account

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

Functions605 in github.com/couler-proj/couler

⨍ Functions 605◇ Types & classes 85
↓ 21 callersMethodconfig_workflow
(self, spec)
couler/tests/test_data/dummy_cluster_config.py:23
↓ 20 callersMethodDescriptor
()
go/couler/proto/couler/v1/couler.pb.go:729
↓ 19 callersMethodcheck_argo_yaml
(self, expected_fn)
couler/tests/argo_yaml_test.py:40
↓ 17 callersMethoddump
(x)
couler/tests/argo_yaml_test.py:48
↓ 16 callersMethodrun
(self)
setup.py:33
↓ 15 callersFunctionflip_coin
()
couler/tests/workflow_basic_test.py:31
↓ 15 callersMethodget_template
(self, name)
couler/core/templates/workflow.py:53
↓ 13 callersFunctionjob
(name)
integration_tests/dag_example.py:24
↓ 13 callersFunctionjob
(name)
examples/dag.py:5
↓ 13 callersMethodto_dict
(self)
couler/core/templates/job.py:50
↓ 12 callersFunction_predicate
Generates an Argo predicate.
couler/core/syntax/predicates.py:15
↓ 12 callersMethodvalues
(cls)
couler/core/constants.py:47
↓ 11 callersMethodGetName
()
go/couler/proto/couler/v1/couler.pb.go:758
↓ 10 callersFunctionjob_a
(message)
couler/tests/dag_test.py:23
↓ 10 callersMethodto_dict
(self)
couler/core/templates/step.py:30
↓ 10 callersMethodto_yaml
Covert the secret to a secret CRD specification.
couler/core/templates/secret.py:46
↓ 10 callersFunctionwhalesay
(hello_param)
couler/tests/run_concurrent_test.py:25
↓ 9 callersFunctionconsumer
(message)
couler/tests/step_output_test.py:32
↓ 9 callersFunctionget_default_proto_workflow
()
couler/core/proto_repr.py:24
↓ 9 callersFunctionproducer
()
couler/tests/step_output_test.py:20
↓ 8 callersFunctionConvertToArgoWorkflow
ConvertToArgoWorkflow converts a workflow from protobuf to an Argo Workflow
go/couler/conversion/argo_workflow.go:17
↓ 8 callersFunction_generate_pod_spec
( pod_template, container_template, allowed_pod_types, pod_type=None, image=None, repl
couler/steps/pod_utils.py:31
↓ 8 callersMethod_oss_check_helper
(self, artifact)
couler/tests/artifact_test.py:28
↓ 8 callersFunctionjob_b
(message)
couler/tests/dag_test.py:32
↓ 8 callersFunctiontails
()
couler/tests/workflow_basic_test.py:41
↓ 7 callersFunctionwhalesay
(hello_param)
couler/tests/input_parameter_test.py:33
↓ 6 callersMethodGetStepIo
()
go/couler/proto/couler/v1/couler.pb.go:363
↓ 6 callersMethodadd_template
(self, template: Template)
couler/core/templates/workflow.py:50
↓ 6 callersMethodcreate_callable_cls
(self, func)
couler/tests/argo_yaml_test.py:59
↓ 6 callersFunctionheads
()
couler/tests/workflow_basic_test.py:35
↓ 6 callersFunctionjob
Create a Workflow run_script job template
examples/depends.py:29
↓ 6 callersFunctionpass_step
(name)
integration_tests/dag_depends_example.py:20
↓ 5 callersMethodGetResources
()
go/couler/proto/couler/v1/couler.pb.go:559
↓ 5 callersMethod__init__
(self, value, is_global=False)
couler/core/templates/output.py:16
↓ 5 callersMethodget_steps_dict
(self)
couler/core/templates/workflow.py:88
↓ 5 callersFunctionjob_c
(message)
couler/tests/dag_test.py:41
↓ 5 callersMethodto_dict
(self)
couler/core/templates/workflow.py:122
↓ 5 callersMethodto_env_list
Convert the secret to an environment list, and can be attached to containers.
couler/core/templates/secret.py:61
↓ 4 callersMethodSubmit
Submit takes an Argo Workflow object and submit it to Kubernetes cluster
go/couler/submitter/argo_submitter.go:30
↓ 4 callersFunction_deserialize_wrapper
(dict_content, response_type)
couler/core/workflow_validation_utils.py:86
↓ 4 callersFunction_parse_single_argo_output
(output, prefix)
couler/core/templates/output.py:52
↓ 4 callersMethodadd_step
(self, name, step: Step)
couler/core/templates/workflow.py:56
↓ 4 callersFunctionflip_coin
()
couler/tests/while_test.py:25
↓ 4 callersMethodverify_concurrent_step
(self, yaml_file_name)
couler/tests/run_concurrent_test.py:44
↓ 4 callersFunctionwrapError
(err error)
go/couler/commands/submit.go:54
↓ 3 callersMethodGetSteps
()
go/couler/proto/couler/v1/couler.pb.go:985
↓ 3 callersMethodGetTmplName
()
go/couler/proto/couler/v1/couler.pb.go:765
↓ 3 callersMethodGetValue
()
go/couler/proto/couler/v1/couler.pb.go:130
↓ 3 callersMethodGetWhen
()
go/couler/proto/couler/v1/couler.pb.go:814
↓ 3 callersMethod__init__
(self, path, type=None, is_global=False)
couler/core/templates/artifact.py:21
↓ 3 callersFunction_update_steps
A step in Argo YAML contains name, related template and parameters. Here we insert a single step into the global steps.
couler/core/step_update_utils.py:132
↓ 3 callersMethod_verify_script_body
( self, script_to_check, image, command, source, env )
couler/tests/argo_test.py:637
↓ 3 callersMethodadd_image_pull_secret
(self, image_pull_secret: ImagePullSecret)
couler/core/templates/workflow.py:79
↓ 3 callersMethodadd_toleration
(self, toleration: Toleration)
couler/core/templates/workflow.py:82
↓ 3 callersFunctionargo_safe_name
Some names are to be used in the Argo YAML file. For example, the generateName and template name in https://github.com/argoproj/argo/blob/mast
couler/core/utils.py:27
↓ 3 callersFunctioncreateSingleStepTemplate
(step *pb.Step, workflowPb *pb.Workflow)
go/couler/conversion/argo_workflow.go:130
↓ 3 callersFunctionjob_d
(message)
couler/tests/dag_test.py:50
↓ 3 callersMethodsubmit
(self, workflow_yaml, secrets=None)
couler/argo_submitter.py:121
↓ 3 callersFunctiontails
()
couler/tests/run_concurrent_test.py:37
↓ 2 callersMethodGetContainerSpec
()
go/couler/proto/couler/v1/couler.pb.go:772
↓ 2 callersMethodGetExitHandlerSteps
()
go/couler/proto/couler/v1/couler.pb.go:1013
↓ 2 callersMethodGetGlobalName
()
go/couler/proto/couler/v1/couler.pb.go:243
↓ 2 callersMethodGetLocalPath
()
go/couler/proto/couler/v1/couler.pb.go:201
↓ 2 callersMethodGetScript
()
go/couler/proto/couler/v1/couler.pb.go:793
↓ 2 callersMethodRun
(w *pb.Workflow)
go/couler/optimization/optimization.go:11
↓ 2 callersFunction_container_output
Generate output name from an Argo container template. For example, "{{steps.generate-parameter.outputs.parameters.hello-param}}" used in http
couler/core/templates/output.py:100
↓ 2 callersMethod_create_secret
(self, secret_yaml)
couler/argo_submitter.py:176
↓ 2 callersFunction_get_params_and_artifacts_from_args
(args, input_param_name, prefix)
couler/core/step_update_utils.py:203
↓ 2 callersMethod_s3_check_helper
(self, artifact)
couler/tests/artifact_test.py:86
↓ 2 callersMethodadd_volume
(self, volume: Volume)
couler/core/templates/workflow.py:70
↓ 2 callersMethodconfig_pod
(self, template)
couler/tests/test_data/dummy_cluster_config.py:19
↓ 2 callersFunctionconsume
(message)
couler/tests/map_test.py:20
↓ 2 callersMethoddag_mode_enabled
(self)
couler/core/templates/workflow.py:102
↓ 2 callersMethodenable_dag_mode
(self)
couler/core/templates/workflow.py:99
↓ 2 callersFunctiongetEntryPointTemplateArgs
(step *pb.Step)
go/couler/conversion/argo_workflow.go:200
↓ 2 callersMethodget_dag_task
(self, name)
couler/core/templates/workflow.py:105
↓ 2 callersFunctionheads
()
couler/tests/dag_test.py:72
↓ 2 callersFunctionheads
()
couler/tests/run_concurrent_test.py:31
↓ 2 callersMethodset_dns
(self, dns_policy, dns_config)
couler/core/templates/workflow.py:118
↓ 2 callersMethodset_security_context
(self, security_context: dict)
couler/core/templates/workflow.py:276
↓ 2 callersMethodto_dict
(self)
couler/core/templates/image_pull_secret.py:21
↓ 2 callersMethodto_dict
(self)
couler/core/templates/volume.py:36
↓ 2 callersFunctionwhalesay_two
(hello_param1, hello_param2)
couler/tests/input_parameter_test.py:39
↓ 2 callersFunctionworkflow_yaml
()
couler/argo.py:52
↓ 1 callersFunctionCompose
Compose sequence optimization passes
go/couler/optimization/optimization.go:32
↓ 1 callersMethodGetAction
()
go/couler/proto/couler/v1/couler.pb.go:630
↓ 1 callersMethodGetArgs
()
go/couler/proto/couler/v1/couler.pb.go:800
↓ 1 callersMethodGetCache
()
go/couler/proto/couler/v1/couler.pb.go:835
↓ 1 callersMethodGetCommand
()
go/couler/proto/couler/v1/couler.pb.go:545
↓ 1 callersMethodGetDependencies
()
go/couler/proto/couler/v1/couler.pb.go:807
↓ 1 callersMethodGetEnv
()
go/couler/proto/couler/v1/couler.pb.go:552
↓ 1 callersMethodGetFailureCondition
()
go/couler/proto/couler/v1/couler.pb.go:623
↓ 1 callersMethodGetImage
()
go/couler/proto/couler/v1/couler.pb.go:538
↓ 1 callersMethodGetInputs
()
go/couler/proto/couler/v1/couler.pb.go:922
↓ 1 callersMethodGetKey
()
go/couler/proto/couler/v1/couler.pb.go:488
↓ 1 callersMethodGetManifest
()
go/couler/proto/couler/v1/couler.pb.go:609
↓ 1 callersMethodGetMaxAge
()
go/couler/proto/couler/v1/couler.pb.go:495
↓ 1 callersMethodGetOutputs
()
go/couler/proto/couler/v1/couler.pb.go:929
↓ 1 callersMethodGetResourceSpec
()
go/couler/proto/couler/v1/couler.pb.go:779
↓ 1 callersMethodGetSetOwnerReference
()
go/couler/proto/couler/v1/couler.pb.go:637
next →1–100 of 605, ranked by callers