mirror of
https://github.com/Hestia-Homes/Model.git
synced 2026-06-08 11:17:27 +00:00
todo list added
This commit is contained in:
parent
aaa1bdc077
commit
2cd24ae3d0
1 changed files with 6 additions and 9 deletions
|
|
@ -2,11 +2,9 @@ from typing import Any
|
|||
import json
|
||||
from utils.logger import setup_logger
|
||||
import logging
|
||||
|
||||
from backend.utils.subtasks import subtask_handler
|
||||
|
||||
logger: logging.Logger = setup_logger()
|
||||
import time
|
||||
|
||||
|
||||
@subtask_handler()
|
||||
|
|
@ -22,16 +20,15 @@ def handler(event: dict[str, Any], context: Any, local: bool = False) -> None:
|
|||
{
|
||||
"task_id": "e31f2f21-175b-4a91-a3ec-a6baa325e917",
|
||||
"sub_task_id": "8673913b-1a88-42d7-8578-0449123d94b0",
|
||||
"s3_uri"
|
||||
}
|
||||
)
|
||||
}
|
||||
]
|
||||
}
|
||||
|
||||
print("sleeping for 30 seconds, subtask should be in progress")
|
||||
raise RuntimeError("test")
|
||||
time.sleep(30)
|
||||
print("subtask should be marked as done")
|
||||
# ------------------------------
|
||||
# YOUR BUSINESS LOGIC HERE
|
||||
# ------------------------------
|
||||
# Add business logic to do handling
|
||||
# TODO: Copy s3_uri importing from address2uprn
|
||||
# TODO: Copy s3_uri logic to read csv from address2uprn and search for ones without UPRN/score is low
|
||||
# TODO: Copy and do ordant survey logic
|
||||
# TODO: Save new results to s3 ( ask Khalim if we want to save to db)
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue