flytekit.interfaces.data package

Submodules

flytekit.interfaces.data.common module

class flytekit.interfaces.data.common.DataProxy[source]

Bases: object

download(remote_path, local_path)[source]
Parameters
  • remote_path (Text) –

  • local_path (Text) –

download_directory(remote_path, local_path)[source]
Parameters
  • remote_path (Text) –

  • local_path (Text) –

exists(path)[source]
Parameters

path

Return type

bool: whether the file exists or not

get_random_directory()[source]
Return type

Text

get_random_path()[source]
Return type

Text

upload(file_path, to_path)[source]
Parameters
  • file_path (Text) –

  • to_path (Text) –

upload_directory(local_path, remote_path)[source]
Parameters
  • local_path (Text) –

  • remote_path (Text) –

flytekit.interfaces.data.data_proxy module

class flytekit.interfaces.data.data_proxy.Data[source]

Bases: object

classmethod data_exists(path)[source]
Parameters

path (Text) –

Return type

bool: whether the file exists or not

classmethod get_data(remote_path, local_path, is_multipart=False)[source]
Parameters
  • remote_path (Text) –

  • local_path (Text) –

  • is_multipart (bool) –

classmethod get_remote_directory()[source]
Return type

Text

classmethod get_remote_path()[source]
Return type

Text

classmethod put_data(local_path, remote_path, is_multipart=False)[source]
Parameters
  • local_path (Text) –

  • remote_path (Text) –

  • is_multipart (bool) –

class flytekit.interfaces.data.data_proxy.LocalDataContext(sandbox)[source]

Bases: flytekit.interfaces.data.data_proxy._OutputDataContext

class flytekit.interfaces.data.data_proxy.LocalWorkingDirectoryContext(directory)[source]

Bases: object

classmethod get()[source]
class flytekit.interfaces.data.data_proxy.RemoteDataContext(cloud_provider=None, raw_output_data_prefix_override=None)[source]

Bases: flytekit.interfaces.data.data_proxy._OutputDataContext

Module contents