diff --git a/hta/common/constants.py b/hta/common/constants.py index 52e4bd97..d984fe65 100644 --- a/hta/common/constants.py +++ b/hta/common/constants.py @@ -6,3 +6,5 @@ # https://forums.developer.nvidia.com/t/maximum-number-of-operations-in-a-stream/255260 # We anecdotally see 1022 - 1024 to cause blocking of runtime operations. CUDA_MAX_LAUNCH_QUEUE_PER_STREAM: int = 1024 + +MAX_EVENT_DURATION_US: int = 604_800_000_000 diff --git a/hta/configs/parser_config.py b/hta/configs/parser_config.py index 4016b401..3cd3cd32 100644 --- a/hta/configs/parser_config.py +++ b/hta/configs/parser_config.py @@ -6,6 +6,7 @@ from typing import Dict, List, Optional, Set, Union import pandas as pd +from hta.common.constants import MAX_EVENT_DURATION_US from hta.configs.default_values import AttributeSpec, EventArgs, ValueType from hta.configs.event_args_yaml_parser import ( parse_event_args_yaml, @@ -113,6 +114,8 @@ def __init__( # config to convert ts to nearest integer self.convert_ts_to_integer = convert_ts_to_integer + self.max_event_duration_us: Optional[int] = MAX_EVENT_DURATION_US + def clone(self) -> "ParserConfig": return copy.deepcopy(self)