ApiKey

Package: flyteplugins.union.remote

Represents a Union API Key (OAuth Application).

API Keys in Union are OAuth 2.0 applications that can be used for headless authentication. They support client credentials flow for machine-to-machine authentication.

Attributes: pb2: The underlying protobuf App message organization: The organization this API key belongs to (for serverless) encoded_credentials: Base64-encoded credentials for UNION_API_KEY env var

Example: # Create a new API key api_key = ApiKey.create(name=“ci-pipeline”) print(f"export FLYTE_API_KEY="{api_key.encoded_credentials}"")

# List all API keys
for key in ApiKey.listall():
    print(f"{key.client_id}: {key.client_name}")

# Get a specific API key
key = ApiKey.get(client_id="my-client-id")

# Delete an API key
ApiKey.delete(client_id="my-client-id")

            
        
class ApiKey(
    pb2: App,
    organization: str | None,
    encoded_credentials: str | None,
)

Parameter	Type	Description
`pb2`	`App`
`organization`	`str \| None`
`encoded_credentials`	`str \| None`

Properties

Property	Type	Description
`client_id`	`None`	The OAuth client ID.
`client_name`	`None`	The human-readable name of the API key.
`client_secret`	`None`	The OAuth client secret (only available on creation).

Methods

Method	Description
`create()`	Create a new API key.
`delete()`	Delete an API key.
`get()`	Get an API key by client ID.
`listall()`	List all API keys.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.
`update()`	Update an API key.

create()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ApiKey.create.aio().

            
        
def create(
    cls,
    name: str,
    redirect_uris: list[str] | None,
) -> ApiKey

Create a new API key.

Parameter	Type	Description
`cls`
`name`	`str`	Human-readable name for the API key
`redirect_uris`	`list[str] \| None`	OAuth redirect URIs (defaults to localhost callback)

delete()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ApiKey.delete.aio().

            
        
def delete(
    cls,
    client_id: str,
)

Delete an API key.

Parameter	Type	Description
`cls`
`client_id`	`str`	The OAuth client ID to delete

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ApiKey.get.aio().

            
        
def get(
    cls,
    client_id: str,
) -> ApiKey

Get an API key by client ID.

Parameter	Type	Description
`cls`
`client_id`	`str`	The OAuth client ID

listall()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ApiKey.listall.aio().

            
        
def listall(
    cls,
    limit: int,
) -> AsyncIterator[ApiKey]

List all API keys.

Parameter	Type	Description
`cls`
`limit`	`int`	Maximum number of keys to return

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

update()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ApiKey.update.aio().

            
        
def update(
    cls,
    client_id: str,
    client_name: str | None,
    redirect_uris: list[str] | None,
) -> ApiKey

Update an API key.

Parameter	Type	Description
`cls`
`client_id`	`str`	The OAuth client ID to update
`client_name`	`str \| None`	New name for the API key
`redirect_uris`	`list[str] \| None`	New redirect URIs