# the final details.
WAIT_FOR_LAVA_POST_PROCESSING_SEC = int(getenv("LAVA_WAIT_LAVA_POST_PROCESSING_SEC", 5))
WAIT_FOR_LAVA_POST_PROCESSING_RETRIES = int(
- getenv("LAVA_WAIT_LAVA_POST_PROCESSING_RETRIES", 3)
+ getenv("LAVA_WAIT_LAVA_POST_PROCESSING_RETRIES", 6)
)
# How many seconds to wait between log output LAVA RPC calls.
getenv("LAVA_NUMBER_OF_RETRIES_TIMEOUT_DETECTION", 2)
)
+
def raise_exception_from_metadata(metadata: dict, job_id: int) -> None:
"""
Investigate infrastructure errors from the job metadata.
if not job.is_post_processed():
waited_for_sec: int = (
- WAIT_FOR_LAVA_POST_PROCESSING_RETRIES * WAIT_FOR_DEVICE_POLLING_TIME_SEC
+ WAIT_FOR_LAVA_POST_PROCESSING_RETRIES
+ * WAIT_FOR_LAVA_POST_PROCESSING_SEC
)
print_log(
- f"Waited for {waited_for_sec} seconds"
+ f"Waited for {waited_for_sec} seconds "
"for LAVA to post-process the job, it haven't finished yet. "
"Dumping it's info anyway"
)
if last_attempt_job.status != "pass":
raise SystemExit(1)
+
class StructuredLoggerWrapper:
def __init__(self, submitter: LAVAJobSubmitter) -> None:
self.__submitter: LAVAJobSubmitter = submitter