iskander
12/12/2022, 11:47 AM@io_manager(required_resource_keys={"k8s_pg"})
def my_iomanager(init_context):
return ioClass(
resource=init_context.resources.k8s_pg
)
Where ioClass has init method self.resource=resource
. The problem I'm having is that the resource inside ioClass is initialized without the env vars. However, the hard coded parameters of the resource are there. I observe this by logging from inside the ioClass logging.critical(_self_.resource.__dict__)
, resource params with os.getenv('xxx')
are None. I've also verified that all the required env vars exist inside my user depl container by executing the shell and running printenv
. The code that I have works if I execute from localhost with dagster job execute ....
. I've also tried adding _`executor_def=in_process_executor`_ to my job decorator which didn't change anything. Any help would be appreciated!daniel
12/12/2022, 3:36 PMiskander
12/12/2022, 5:32 PMdaniel
12/12/2022, 5:37 PM