AsyncClient

This class provides an asynchronous interface for interacting with a catalog service. It supports operations to download existing entries and upload new entries to the catalog.

Methods

---

Download()

@classmethod
def Download(
    ctx: context.Context,
    requests: [DownloadRequest](downloadrequest.md?sid=flyteplugins_go_tasks_pluginmachinery_catalog_downloadrequest)
) - > outputFuture DownloadFuture

Returns if an entry exists for the given task and input. It returns the data as a LiteralMap

Parameters

Name	Type	Description
ctx	context.Context	The context for the operation, allowing cancellation and carrying request-scoped values.
requests	[DownloadRequest](downloadrequest.md?sid=flyteplugins_go_tasks_pluginmachinery_catalog_downloadrequest)	The download requests to be processed.

Returns

Type	Description
outputFuture DownloadFuture	The future result of the download operation.

---

Upload()

@classmethod
def Upload(
    ctx: context.Context,
    requests: [UploadRequest](uploadrequest.md?sid=flyteplugins_go_tasks_pluginmachinery_catalog_uploadrequest)
) - > putFuture UploadFuture

Adds a new entry to catalog for the given task execution context and the generated output

Parameters

Name	Type	Description
ctx	context.Context	The context for the operation, allowing cancellation and carrying request-scoped values.
requests	[UploadRequest](uploadrequest.md?sid=flyteplugins_go_tasks_pluginmachinery_catalog_uploadrequest)	The upload requests to be processed.

Returns

Type	Description
putFuture UploadFuture	The future result of the upload operation.

---