kubeflow.fairing package¶
Subpackages¶
- kubeflow.fairing.backends package
- kubeflow.fairing.builders package
- kubeflow.fairing.cloud package
- kubeflow.fairing.constants package
- kubeflow.fairing.deployers package
- kubeflow.fairing.frameworks package
- kubeflow.fairing.functions package
- kubeflow.fairing.kubernetes package
- kubeflow.fairing.ml_tasks package
- kubeflow.fairing.notebook package
- kubeflow.fairing.preprocessors package
Submodules¶
kubeflow.fairing.config module¶
-
class
kubeflow.fairing.config.Config¶ Bases:
object-
deploy(pod_spec)¶ deploy the job
Parameters: pod_spec – pod spec of the job
-
fn(fn)¶ function
Parameters: fn – return func that set the preprocessorr and run
-
get_builder(preprocessor)¶ get the builder
Parameters: preprocessor – preprocessor function
-
get_deployer()¶ get deployer
-
get_preprocessor()¶ get the preprocessor
-
reset()¶ reset the preprocessor, builder_name and deployer name
-
run()¶ run the pipeline for job
-
set_builder(name='append', **kwargs)¶ set the builder
Parameters: name – builder name (Default value = DEFAULT_BUILDER)
-
set_deployer(name='job', **kwargs)¶ set the deployer
Parameters: name – deployer name (Default value = DEFAULT_DEPLOYER)
-
set_preprocessor(name=None, **kwargs)¶ Parameters: name – preprocessor name(Default value = None)
-
kubeflow.fairing.http_utils module¶
-
kubeflow.fairing.http_utils.configure_http_instance(http=None)¶ Configure http instance to modify the request headers to append or modify user-agent.
Parameters: http – Body of googleapiclient (Default value = None) Returns: object: Configurated http contents.
kubeflow.fairing.runtime_config module¶
-
class
kubeflow.fairing.runtime_config.RuntimeConfig¶ Bases:
objectA passthrough config shim that runs in the fairing runtime
-
fn(func)¶
-
get_builder()¶
-
get_deployer(**kwargs)¶
-
get_preprocessor()¶
-
reset()¶
-
run()¶
-
set_builder(name, **kwargs)¶
-
set_deployer(name, **kwargs)¶
-
set_preprocessor(name, **kwargs)¶
-
kubeflow.fairing.utils module¶
-
kubeflow.fairing.utils.crc(file_name)¶ Compute a running Cyclic Redundancy Check checksum.
Parameters: file_name – The file name that’s for crc checksum.
-
kubeflow.fairing.utils.get_current_k8s_namespace()¶ Get the current namespace of kubernetes.
-
kubeflow.fairing.utils.get_default_target_namespace()¶ Get the default target namespace, if running in the kubernetes cluster, will be current namespace, Otherwiase, will be “default”.
-
kubeflow.fairing.utils.get_image(repository, name)¶ Get the full image name by integrating repository and image name.
Parameters: - repository – The name of repository
- name – The short image name
Returns: str: Full image name, format: repo/name.
-
kubeflow.fairing.utils.is_running_in_k8s()¶ Check if running in the kubernetes cluster.
-
kubeflow.fairing.utils.random_tag()¶ Get a random tag.