Louis Auneau
07/27/2023, 8:57 PMConfigurableResources
, or ResourceParam
, but it seems none of them offers the flexibility we had before to get a fully functional SDK configured in a resource.
Former code:
from dagster import resource, Field
from my_sdk import SDKClient
@resource(config_schema={"some-conf": Field(str)}
def my_sdk(context: InitResourceContext) -> SDKClient:
return SDKClient(context.resource_config["some-conf"])
@op(required_resource_keys={'my_sdk'})
def my_op(context):
my_sdk: SDKClient = context.resources.my_sdk
my_sdk.my_func()
Thanks by advance and have a nice day!
Louis