MCPcopy Create free account

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

Functions605 in github.com/couler-proj/couler

MethodXXX_Marshal
(b []byte, deterministic bool)
go/couler/proto/couler/v1/couler.pb.go:664
MethodXXX_Marshal
(b []byte, deterministic bool)
go/couler/proto/couler/v1/couler.pb.go:736
MethodXXX_Marshal
(b []byte, deterministic bool)
go/couler/proto/couler/v1/couler.pb.go:859
MethodXXX_Marshal
(b []byte, deterministic bool)
go/couler/proto/couler/v1/couler.pb.go:900
MethodXXX_Marshal
(b []byte, deterministic bool)
go/couler/proto/couler/v1/couler.pb.go:963
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:49
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:104
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:168
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:270
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:315
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:421
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:469
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:526
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:597
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:667
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:739
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:862
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:903
MethodXXX_Merge
(src proto.Message)
go/couler/proto/couler/v1/couler.pb.go:966
MethodXXX_OneofWrappers
XXX_OneofWrappers is for the internal use of the proto package.
go/couler/proto/couler/v1/couler.pb.go:392
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:52
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:107
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:171
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:273
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:318
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:424
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:472
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:529
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:600
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:670
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:742
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:865
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:906
MethodXXX_Size
()
go/couler/proto/couler/v1/couler.pb.go:969
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:43
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:98
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:162
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:264
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:309
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:415
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:463
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:520
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:591
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:661
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:733
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:856
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:897
MethodXXX_Unmarshal
(b []byte)
go/couler/proto/couler/v1/couler.pb.go:960
Method__call__
(self, *args)
couler/tests/argo_yaml_test.py:72
Method__init__
( self, namespace="default", config_file=None, context=None, client_co
couler/argo_submitter.py:39
Method__init__
(self, key, effect, operator)
couler/core/templates/toleration.py:18
Method__init__
(self, workflow_filename)
couler/core/templates/workflow.py:28
Method__init__
(self, nameservers=None, options=None, searches=None)
couler/core/templates/dns.py:20
Method__init__
(self, name, value)
couler/core/templates/dns.py:43
Method__init__
(self, name)
couler/core/templates/image_pull_secret.py:18
Method__init__
( self, name, image, command, source, args=None, env=N
couler/core/templates/script.py:24
Method__init__
( self, namespace, data, name=None, dry_run=False, use_existing=False, artifact_secret=False )
couler/core/templates/secret.py:22
Method__init__
(self, name, steps=None)
couler/core/templates/step.py:44
Method__init__
(self, name, key, max_age="")
couler/core/templates/cache.py:18
Method__init__
( self, name, args, action, manifest, set_owner_reference,
couler/core/templates/job.py:21
Method__init__
(self, value, is_global=False)
couler/core/templates/output.py:22
Method__init__
(self, value, is_global=False)
couler/core/templates/output.py:27
Method__init__
(self, value, path, artifact, is_global=False, type="")
couler/core/templates/output.py:32
Method__init__
(self, value, is_global=False)
couler/core/templates/output.py:40
Method__init__
(self, value, job_name, job_id, job_obj=None, is_global=False)
couler/core/templates/output.py:45
Method__init__
( self, artifact_type, path, accesskey_id=None, accesskey_secret=None,
couler/core/templates/artifact.py:49
Method__init__
(self, path, is_global=False)
couler/core/templates/artifact.py:114
Method__init__
( self, path, accesskey_id, accesskey_secret, bucket, key=None
couler/core/templates/artifact.py:121
Method__init__
( self, path, accesskey_id, accesskey_secret, bucket, key=None
couler/core/templates/artifact.py:146
Method__init__
(self, claim_name: str, access_modes: List[str], size: str)
couler/core/templates/volume_claim.py:19
Method__init__
( self, name, image, command, args=None, env=None, env
couler/core/templates/container.py:26
Method__init__
(self, name, claim_name)
couler/core/templates/volume.py:18
Method__init__
(self, name, mount_path)
couler/core/templates/volume.py:32
Method__init__
( self, name, output=None, input=None, timeout=None, retry=Non
couler/core/templates/template.py:20
Method__init__
(self)
couler/tests/test_data/dummy_cluster_config.py:16
Function_dump_yaml
()
couler/argo.py:154
Method_verify_script_body
( self, script_to_check, image, command, source, env )
couler/tests/secret_test.py:58
Methoda
(self)
couler/tests/dag_test.py:128
Methoda
(self, *args)
couler/tests/argo_yaml_test.py:61
Functionadd_deps_to_step
(step_name)
couler/core/proto_repr.py:191
Functionadd_image_pull_secret
Add image pull secret to the workflow.
couler/core/syntax/image_pull_secret.py:18
Functionadd_toleration
Add toleration to the workflow.
couler/core/syntax/toleration.py:18
Functionadd_volume
Add existing volume to the workflow. Reference: https://github.com/argoproj/argo/blob/master/examples/volumes-existing.yaml
couler/core/syntax/volume.py:19
Functionall_failed
()
examples/depends.py:44
Functionany_succeeded
()
examples/depends.py:40
Methodb
()
couler/tests/dag_test.py:132
Methodb
(cls, *args)
couler/tests/argo_yaml_test.py:65
Functionbigger
(pre, post=None)
couler/core/syntax/predicates.py:49
Functionbigger_equal
(pre, post=None)
couler/core/syntax/predicates.py:63
Functionbody
If a function A calls body(), the call returns the Python source code of the function definition body (not including the signature) of A.
couler/core/utils.py:77
Functionbool_to_str
convert boolean to strings for YAML configuration
couler/core/utils.py:272
Methodc
(cls)
couler/tests/dag_test.py:136
Methodc
(*args)
couler/tests/argo_yaml_test.py:69
Functionconcurrent
Start different jobs at the same time subtasks: each function F of function_list contains multiple steps. Then, for each F, we create a s
couler/core/syntax/concurrent.py:21
Functionconfig_defaults
Config couler defaults. :param name_salter: function to salt workflow names. :param service_account: name of the default Kubernetes
couler/core/config.py:19
Functionconfig_image_pull_policy
(policy)
couler/core/utils.py:230
Functionconfig_retry_strategy
Generate retry strategy.
couler/core/utils.py:223
Functionconfig_workflow
Config some workflow-level information. :param name: name of the workflow. :param user_id: user information. :param timeout: maximum
couler/core/config.py:34
Methodconsume_two
(message)
couler/tests/step_output_test.py:62
Methodconsume_two
(step_name)
couler/tests/dag_test.py:161
← previousnext →301–400 of 605, ranked by callers