flytekit.core.data_persistence.DataPersistencePlugins#

class flytekit.core.data_persistence.DataPersistencePlugins[source]#

DataPersistencePlugins is the core plugin registry that stores all DataPersistence plugins. To add a new plugin use

DataPersistencePlugins.register_plugin("s3:/", DataPersistence(), force=True|False)

These plugins should always be registered. Follow the plugin registration guidelines to auto-discover your plugins.

Methods

classmethod find_plugin(path)[source]#

Returns a plugin for the given protocol, else raise a TypeError

Parameters

path (str) –

Return type

Type[flytekit.core.data_persistence.DataPersistence]

static get_protocol(url)[source]#
Parameters

url (str) –

classmethod is_supported_protocol(protocol)[source]#

Returns true if the given protocol is has a registered plugin for it

Parameters

protocol (str) –

Return type

bool

classmethod print_all_plugins()[source]#

Prints all the plugins and their associated protocoles

classmethod register_plugin(protocol, plugin, force=False)[source]#

Registers the supplied plugin for the specified protocol if one does not already exist. If one exists and force is default or False, then a TypeError is raised. If one does not exist then it is registered If one exists, but force == True then the existing plugin is overridden

Parameters
classmethod supported_protocols()[source]#
Return type

List[str]