diff --git a/cdk/lib/ecs-stack.ts b/cdk/lib/ecs-stack.ts index 2109532..0ad9f82 100644 --- a/cdk/lib/ecs-stack.ts +++ b/cdk/lib/ecs-stack.ts @@ -506,6 +506,10 @@ export class EcsStack extends cdk.Stack { ecsProsessiOnKaynnissaTable.grantReadWriteData( lampiSiirtajaScheduledFargateTask.taskDefinition.taskRole ); + ecsProsessiOnKaynnissaTable.grant( + lampiSiirtajaScheduledFargateTask.taskDefinition.taskRole, + ...['dynamodb:PartiQLSelect', 'dynamodb:PartiQLUpdate'] + ); lampiSiirtajaScheduledFargateTask.taskDefinition.addToExecutionRolePolicy( new iam.PolicyStatement({ diff --git a/dbt-container/run.sh b/dbt-container/run.sh index 155a723..89aa7ea 100755 --- a/dbt-container/run.sh +++ b/dbt-container/run.sh @@ -10,7 +10,8 @@ cd dbt . venv/bin/activate IS_RUNNING=$(aws dynamodb execute-statement --statement "SELECT onKaynnissa FROM ecsProsessiOnKaynnissa WHERE prosessi='dbt-scheduled-task'" | jq ' .Items.[0].onKaynnissa.S ') -if [ $IS_RUNNING == "true" ] ; then +echo "Onko edellinen ajo käynnissä: $IS_RUNNING" +if [[ "$IS_RUNNING" == "true" ]]; then echo "ERROR: Edellinen ajo on vielä käynnissä." exit 1 fi diff --git a/lampi-siirtaja-container/run.sh b/lampi-siirtaja-container/run.sh index cb49e4f..ac8e848 100755 --- a/lampi-siirtaja-container/run.sh +++ b/lampi-siirtaja-container/run.sh @@ -5,7 +5,8 @@ set -e echo "Running Lampi-siirtäjä..." IS_RUNNING=$(aws dynamodb execute-statement --statement "SELECT onKaynnissa FROM ecsProsessiOnKaynnissa WHERE prosessi='lampi-scheduled-task'" | jq ' .Items.[0].onKaynnissa.S ') -if [ $IS_RUNNING == "true" ] ; then +echo "Onko edellinen ajo käynnissä: $IS_RUNNING" +if [[ "$IS_RUNNING" == "true" ]]; then echo "ERROR: Edellinen ajo on vielä käynnissä." exit 1 fi