SQLite3 task#

class flytekit.extras.sqlite3.task.SQLite3Task(*args, **kwargs)#

Run client side SQLite3 queries that optionally return a FlyteSchema object.

Note

This is a pre-built container task. That is, your user container will not be used at task execution time. Instead the image defined in this task definition will be used instead.

See the integrations guide for additional usage examples and the base class flytekit.extend.PythonCustomizedContainerTask as well.

get_custom(settings)#

Return additional plugin-specific custom data (if any) as a serializable dictionary.

Parameters:

settings (SerializationSettings)

Return type:

Dict[str, Any]

class flytekit.extras.sqlite3.task.SQLite3Config(uri, compressed=False)#

Use this configuration to configure if sqlite3 files that should be loaded by the task. The file itself is considered as a database and hence is treated like a configuration The path to a static sqlite3 compatible database file can be

  • within the container

  • or from a publicly downloadable source

Args:

uri: default FlyteFile that will be downloaded on execute compressed: Boolean that indicates if the given file is a compressed archive. Supported file types are

[zip, tar, gztar, bztar, xztar]

Parameters:

  • uri (str)

  • compressed (bool)