Corris Randall
08/05/2022, 8:41 PMfrom typing import Optional
from prefect.utilities.asyncutils import sync_compatible
from prefect.blocks.notifications import NotificationBlock
class MyEmail(NotificationBlock):
_block_type_name = "My Email"
_block_type_slug = "my-email"
_block_schema_capabilities = ["notify"]
@sync_compatible
async def notify(self,body: str,subject: Optional[str] = None):
await print( f"In my email notify subject: {subject}\nbody: {body}" )
Anna Geller
Corris Randall
08/05/2022, 11:29 PMJeremiah
Corris Randall
08/06/2022, 12:43 AM