millions-librarian-58501
02/15/2023, 7:57 AM@task(secret_requests=[Secret(group="SOME_SECRET", key="DATA")])
def some_task() -> None:
...
os.environ["SOME_SECRET_DATA"] = flytekit.current_context().secrets.get("SOME_SECRET", "DATA")
...
It works fine on remote because k8s secrets are already set. However, it doesn’t works on local with command pyflyte run …
. When I use SecretsManager under if __name__ == "__main__"
clause and run with python pipeline.py
it works. But I want to make this pipeline works with pyflyte run …
command.tall-lock-23197