Chris Gunderson
09/27/2022, 9:10 PM@task(name='Get Email Credentials',
retries = 2,
retry_delay_seconds = 10)
async def GetEmailCredentials(aws_credentials: AwsCredentials) -> EmailCredentials:
session = aws_credentials.get_boto3_session()
secrets_client = session.client(service_name='secretsmanager')
aws_secret = secrets_client.get_secret_value(SecretId='DEV_EMAIL')
secret_json = aws_secret['SecretString']
emailDict = json.loads(secret_json)
return EmailCredentials(emailDict)
Nate
09/27/2022, 9:22 PMfrom prefect import task
in the file where you're defining GetEmailCredentials
?Chris Gunderson
09/27/2022, 9:24 PMimport prefect
import json
from prefect_aws import AwsCredentials
from prefect import tasks
@task(name='Get Email Credentials',
retries = 2,
retry_delay_seconds = 10)
async def GetEmailCredentials(aws_credentials: AwsCredentials) -> EmailCredentials:
session = aws_credentials.get_boto3_session()
secrets_client = session.client(service_name='secretsmanager')
aws_secret = secrets_client.get_secret_value(SecretId='DEV_EMAIL')
secret_json = aws_secret['SecretString']
emailDict = json.loads(secret_json)
return EmailCredentials(emailDict)
Nate
09/27/2022, 9:26 PMtask
😄
from prefect import tasks
Chris Gunderson
09/27/2022, 9:27 PMNate
09/27/2022, 9:29 PM~/.aws/credentials
profile and for like a half hour I was like "what is going on?!?!" haha it happensChris Gunderson
09/27/2022, 9:30 PMNate
09/27/2022, 9:31 PM