Set start time of extractors. (#458)

Author: toondaey

cognite/extractorutils/unstable/core/base.py

@@ -47,6 +47,7 @@ def my_task_function(self, task_context: TaskContext) -> None:
 import logging
 import time
 from concurrent.futures import ThreadPoolExecutor
+from datetime import datetime, timezone
 from functools import partial
 from logging.handlers import TimedRotatingFileHandler
 from multiprocessing import Queue
@@ -146,6 +147,7 @@ def __init__(self, config: FullConfig[ConfigType]) -> None:
         self._tasks: list[Task] = []
         self._task_updates: list[TaskUpdate] = []
         self._errors: dict[str, Error] = {}
+        self._start_time: datetime
 
         self.__init_tasks__()
 
@@ -435,6 +437,7 @@ def run(self) -> None:
             with extractor:
                 extractor.run()
         """
+        self._start_time = datetime.now(tz=timezone.utc)
         has_scheduled = False
 
         startup: list[StartupTask] = []