szalai1
08/27/2020, 2:46 PMCeleryK8sRunLauncher
and celery-k8s
executor. Using s3 as storage.
To give jobs access to S3 buckets I used dagster-k8s/config
tag and annotate the pods with the right role.
When I'm running the pipeline:
An exception was thrown during execution that is likely a framework error, rather than an error in user code.
botocore.exceptions.ClientError: An error occurred (403) when calling the HeadBucket operation: Forbidden
The only pod which doens't have the role annotation is CeleryK8sRunLauncher.
I'm wondering is this error coming from that and if yes how can I annotate it?johann
08/27/2020, 3:28 PMszalai1
08/27/2020, 8:30 PMtags
to my pipeline:
annotations = {
'dagster-k8s/config': {
'pod_template_spec_metadata': {
'annotations': {
"<http://iam.amazonaws.com/role:|iam.amazonaws.com/role:>": "arn:aws:iam::xxxxxxxxx:role/ETLEKSPodRole"
}
}
},
}
and getting the error below, which is odd because this should be a valid annotation. based on : https://kubernetes.io/docs/concepts/overview/working-with-objects/annotations/#syntax-and-character-setjohann
08/27/2020, 9:32 PMsashank
08/27/2020, 9:33 PMk describe pod/podname
k describe job/jobname
johann
08/27/2020, 9:33 PMsashank
08/27/2020, 9:33 PMszalai1
08/27/2020, 9:36 PM:
in the annotation name, the error message was correct. sorry for noise. 🤦sashank
08/27/2020, 9:37 PMszalai1
08/27/2020, 9:38 PM