Skip to content

Commit

Permalink
Merge pull request #10 from AllenInstitute/feature/add-efs-cleanup-sf…
Browse files Browse the repository at this point in the history
…n-fragments

Adding EFS Cleanup Utility State Machine Fragments
  • Loading branch information
rpmcginty authored Jun 11, 2024
2 parents 5563f55 + 0701e56 commit 9f9312b
Show file tree
Hide file tree
Showing 8 changed files with 766 additions and 354 deletions.
47 changes: 23 additions & 24 deletions src/aibs_informatics_cdk_lib/constructs_/batch/infrastructure.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,6 @@
BATCH_READ_ONLY_ACTIONS,
S3_READ_ONLY_ACCESS_ACTIONS,
batch_policy_statement,
dynamodb_policy_statement,
lambda_policy_statement,
)
from aibs_informatics_cdk_lib.constructs_.base import EnvBaseConstruct
from aibs_informatics_cdk_lib.constructs_.batch.launch_template import IBatchLaunchTemplateBuilder
Expand All @@ -40,6 +38,17 @@

class Batch(EnvBaseConstruct):
"""
Out of the box Batch construct that can be used to create multiple Batch Environments.
This construct creates simplifies the creation of Batch Environments.
It allows for the creation of multiple Batch Environments with different configurations
and launch templates, but using the same instance role and security group.
Notes:
- Instance Roles are created with a set of managed policies that are commonly used
by Batch jobs. It also includes custom resources to allow access to S3, Lambda, and DynamoDB.
Defines:
- Batch Compute Environment (Spot and OnDemand)
- Instance Role
Expand All @@ -53,6 +62,7 @@ def __init__(
id: str,
env_base: EnvBase,
vpc: ec2.IVpc,
instance_role_name: Optional[str] = None,
instance_role_policy_statements: Optional[List[iam.PolicyStatement]] = None,
) -> None:
super().__init__(scope, id, env_base)
Expand All @@ -64,8 +74,11 @@ def __init__(
# - security group
# - launch template
# ---------------------------------------------------------------------
self.instance_role = self.create_instance_role(instance_role_policy_statements)
self.instance_profile = self.create_instance_profile()
self.instance_role = self.create_instance_role(
role_name=instance_role_name,
statements=instance_role_policy_statements,
)
self.instance_profile = self.create_instance_profile(self.instance_role.role_name)
self.security_group = self.create_security_group()

self._batch_environment_mapping: MutableMapping[str, BatchEnvironment] = {}
Expand All @@ -77,11 +90,14 @@ def environments(self) -> List["BatchEnvironment"]:
)

def create_instance_role(
self, statements: Optional[List[iam.PolicyStatement]] = None
self,
role_name: Optional[str] = None,
statements: Optional[List[iam.PolicyStatement]] = None,
) -> iam.Role:
instance_role = iam.Role(
self,
self.get_child_id(self, f"instance-role"),
role_name=role_name,
description="Role used by ec2 instance in batch compute environment",
assumed_by=iam.ServicePrincipal("ec2.amazonaws.com"), # type: ignore # Interface not inferred
)
Expand Down Expand Up @@ -152,23 +168,6 @@ def create_instance_role(
resources=["*"],
),
batch_policy_statement(actions=BATCH_READ_ONLY_ACTIONS, env_base=self.env_base),
lambda_policy_statement(actions=["lambda:InvokeFunction"], env_base=self.env_base),
dynamodb_policy_statement(
env_base=self.env_base,
sid="DynamoDBReadWrite",
actions=[
"dynamodb:BatchGet*",
"dynamodb:DescribeStream",
"dynamodb:DescribeTable",
"dynamodb:Get*",
"dynamodb:Query",
"dynamodb:Scan",
"dynamodb:BatchWrite*",
"dynamodb:Delete*",
"dynamodb:Update*",
"dynamodb:PutItem",
],
),
],
roles=[instance_role], # type: ignore # Role is not inferred as IRole
)
Expand All @@ -184,11 +183,11 @@ def create_instance_role(

return instance_role

def create_instance_profile(self) -> iam.CfnInstanceProfile:
def create_instance_profile(self, instance_role_name: str) -> iam.CfnInstanceProfile:
return iam.CfnInstanceProfile(
self,
f"instance-profile",
roles=[self.instance_role.role_name],
roles=[instance_role_name],
)

def create_security_group(self) -> ec2.SecurityGroup:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ def end_states(self) -> List[sfn.INextable]:

def enclose(
self,
id: str,
id: Optional[str] = None,
input_path: Optional[str] = None,
result_path: Optional[str] = None,
) -> sfn.Chain:
Expand All @@ -193,6 +193,8 @@ def enclose(
Returns:
sfn.Chain: the new state machine fragment
"""
id = id or self.node.id

if input_path is None:
input_path = "$"
if result_path is None:
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
from aibs_informatics_cdk_lib.constructs_.sfn.fragments.informatics.batch import (
BatchInvokedExecutorFragment,
BatchInvokedLambdaFunction,
)
from aibs_informatics_cdk_lib.constructs_.sfn.fragments.informatics.data_sync import (
DataSyncFragment,
)
from aibs_informatics_cdk_lib.constructs_.sfn.fragments.informatics.demand_execution import (
DemandExecutionFragment,
)
from aibs_informatics_cdk_lib.constructs_.sfn.fragments.informatics.efs import (
CleanFileSystemFragment,
CleanFileSystemTriggerConfig,
)
Loading

0 comments on commit 9f9312b

Please sign in to comment.