diff --git a/chimerapy/engine/chimerapyrc.yaml b/chimerapy/engine/chimerapyrc.yaml
index 7f826f48..bcc2d9b9 100644
--- a/chimerapy/engine/chimerapyrc.yaml
+++ b/chimerapy/engine/chimerapyrc.yaml
@@ -39,3 +39,5 @@ config:
     deque-length: 10000
     interval: 10
     logging-enabled: false
+  sync:
+    attempts: 10
diff --git a/chimerapy/engine/clock.py b/chimerapy/engine/clock.py
new file mode 100644
index 00000000..59fc1c24
--- /dev/null
+++ b/chimerapy/engine/clock.py
@@ -0,0 +1,27 @@
+from datetime import datetime, timedelta
+import ntplib
+import time
+
+from chimerapy.engine import config
+
+# Globals
+time_delta = timedelta(0)
+
+
+def sync():
+    global time_delta
+    ntp_client = ntplib.NTPClient()
+    for i in range(config.get("sync.attempts")):
+        try:
+            response = ntp_client.request("pool.ntp.org")
+            time_delta = timedelta(seconds=response.offset)
+        except:
+            time.sleep(0.5)
+
+
+def utcnow() -> datetime:
+    return datetime.utcnow() + time_delta
+
+
+def now() -> datetime:
+    return utcnow()
diff --git a/chimerapy/engine/data_protocols.py b/chimerapy/engine/data_protocols.py
index 1d85553d..1467d0f3 100644
--- a/chimerapy/engine/data_protocols.py
+++ b/chimerapy/engine/data_protocols.py
@@ -1,9 +1,10 @@
-import datetime
 from typing import Dict
 from dataclasses import dataclass, field
 
 from dataclasses_json import DataClassJsonMixin
 
+from chimerapy.engine import clock
+
 
 @dataclass
 class NodePubEntry(DataClassJsonMixin):
@@ -19,7 +20,7 @@ class NodePubTable(DataClassJsonMixin):
 @dataclass
 class NodeDiagnostics(DataClassJsonMixin):
     timestamp: str = field(
-        default_factory=lambda: str(datetime.datetime.now().isoformat())
+        default_factory=lambda: str(clock.now().isoformat())
     )  # ISO str
     latency: float = 0  # ms
     payload_size: float = 0  # KB
diff --git a/chimerapy/engine/eventbus/eventbus.py b/chimerapy/engine/eventbus/eventbus.py
index 08023c3c..c655fa9e 100644
--- a/chimerapy/engine/eventbus/eventbus.py
+++ b/chimerapy/engine/eventbus/eventbus.py
@@ -1,6 +1,5 @@
 import uuid
 import asyncio
-from datetime import datetime
 from collections import deque
 from concurrent.futures import Future
 from typing import Any, Generic, Type, Callable, Awaitable, Optional, Literal, TypeVar
@@ -8,6 +7,7 @@
 from aioreactive import AsyncObservable, AsyncObserver, AsyncSubject
 from dataclasses import dataclass, field
 
+from chimerapy.engine import clock
 from .. import _logger
 from ..networking.async_loop_thread import AsyncLoopThread
 
@@ -21,7 +21,7 @@ class Event:
     type: str
     data: Optional[Any] = None
     id: str = field(default_factory=lambda: str(uuid.uuid4()))
-    timestamp: str = field(default_factory=lambda: datetime.utcnow().isoformat())
+    timestamp: str = field(default_factory=lambda: clock.now().isoformat())
 
 
 class EventBus(AsyncObservable):
diff --git a/chimerapy/engine/logger/common.py b/chimerapy/engine/logger/common.py
index ea1ad302..45b0b4a9 100644
--- a/chimerapy/engine/logger/common.py
+++ b/chimerapy/engine/logger/common.py
@@ -1,10 +1,11 @@
 import logging
-from datetime import datetime
 from logging import Filter, Formatter, Handler, StreamHandler
 from logging.handlers import RotatingFileHandler
 from pathlib import Path
 from typing import Union, Dict
 
+from chimerapy.engine import clock
+
 MAX_BYTES_PER_FILE = 100 * 1024 * 1024  # 100MB
 
 
@@ -117,7 +118,7 @@ def emit(self, record: logging.LogRecord):
     @staticmethod
     def timestamp() -> str:
         """Return the current timestamp in the format YYYY-MM-DD_HH-MM-SS."""
-        return datetime.now().strftime("%Y-%m-%d_%H-%M-%S")
+        return clock.now().strftime("%Y-%m-%d_%H-%M-%S")
 
 
 class MultiplexedRotatingFileHandler(MultiplexedEntityHandler):
diff --git a/chimerapy/engine/manager/http_server_service.py b/chimerapy/engine/manager/http_server_service.py
index c5ad83d3..ff29068a 100644
--- a/chimerapy/engine/manager/http_server_service.py
+++ b/chimerapy/engine/manager/http_server_service.py
@@ -1,4 +1,5 @@
 import traceback
+import datetime
 from concurrent.futures import Future
 from typing import List, Dict
 
@@ -143,6 +144,7 @@ async def _register_worker_route(self, request: web.Request):
                 "port": self.port,
             },
             "config": config.config,
+            "manager_datetime_now": datetime.datetime.utcnow().isoformat(),
         }
 
         # Broadcast changes
@@ -168,7 +170,6 @@ async def _update_nodes_status(self, request: web.Request):
             update_dataclass(self.state.workers[worker_state.id], worker_state)
         else:
             logger.error(f"{self}: non-registered Worker update: {worker_state.id}")
-        # logger.debug(f"{self}: Nodes status update to: {self.state.workers}")
 
         return web.HTTPOk()
 
diff --git a/chimerapy/engine/manager/worker_handler_service.py b/chimerapy/engine/manager/worker_handler_service.py
index 539b54b2..1e77cbca 100644
--- a/chimerapy/engine/manager/worker_handler_service.py
+++ b/chimerapy/engine/manager/worker_handler_service.py
@@ -105,13 +105,9 @@ def _get_worker_ip(self, worker_id: str) -> str:
 
     async def _register_worker(self, worker_state: WorkerState) -> bool:
 
-        logger.debug(f"{self}: worker_state: {worker_state} BEFORE")
         evented_worker_state = make_evented(
             worker_state, event_bus=self.eventbus, event_name="ManagerState.changed"
         )
-        logger.debug(
-            f"{self}: worker_state: {worker_state}: {evented_worker_state} AFTER"
-        )
         self.state.workers[worker_state.id] = evented_worker_state
         logger.debug(
             f"Manager registered <Worker id={worker_state.id}"
diff --git a/chimerapy/engine/networking/data_chunk.py b/chimerapy/engine/networking/data_chunk.py
index a4b4d363..a8aeda53 100644
--- a/chimerapy/engine/networking/data_chunk.py
+++ b/chimerapy/engine/networking/data_chunk.py
@@ -2,7 +2,6 @@
 import pickle
 import uuid
 import blosc
-import datetime
 from typing import Any, Literal, Dict, List
 
 # Third-party Imports
@@ -10,6 +9,7 @@
 import simplejpeg
 
 # Internal Imports
+from chimerapy.engine import clock
 from chimerapy.engine._logger import getLogger
 
 logger = getLogger("chimerapy-engine")
@@ -40,7 +40,7 @@ def __init__(self):
         self._container["meta"] = {
             "value": {
                 "ownership": [],
-                "created": datetime.datetime.now(),
+                "created": clock.now(),
                 "transmitted": None,
                 "received": None,
             },
diff --git a/chimerapy/engine/node/node.py b/chimerapy/engine/node/node.py
index 6da253ec..ca1ae025 100644
--- a/chimerapy/engine/node/node.py
+++ b/chimerapy/engine/node/node.py
@@ -1,7 +1,6 @@
 import pathlib
 import logging
 import uuid
-import datetime
 import os
 import tempfile
 import asyncio
@@ -15,7 +14,7 @@
 
 # Internal Imports
 from chimerapy.engine import _logger
-from chimerapy.engine import config
+from chimerapy.engine import clock
 from ..states import NodeState
 from ..networking import DataChunk
 from ..networking.async_loop_thread import AsyncLoopThread
@@ -89,7 +88,7 @@ def __init__(
         # Generic Node needs
         self.logger: logging.Logger = logging.getLogger("chimerapy-engine-node")
         self.logging_level: int = logging.DEBUG
-        self.start_time = datetime.datetime.now()
+        self.start_time = clock.now()
 
         # Default values
         self.node_config = NodeConfig()
@@ -200,7 +199,7 @@ def save_video(self, name: str, data: np.ndarray, fps: int):
             return False
 
         if self.recorder.enabled:
-            timestamp = datetime.datetime.now()
+            timestamp = clock.now()
             video_entry = {
                 "uuid": uuid.uuid4(),
                 "name": name,
@@ -251,7 +250,7 @@ def save_audio(
                 "channels": channels,
                 "format": format,
                 "rate": rate,
-                "timestamp": datetime.datetime.now(),
+                "timestamp": clock.now(),
             }
             self.recorder.submit(audio_entry)
 
@@ -271,7 +270,7 @@ def save_tabular(
                 "name": name,
                 "data": data,
                 "dtype": "tabular",
-                "timestamp": datetime.datetime.now(),
+                "timestamp": clock.now(),
             }
             self.recorder.submit(tabular_entry)
 
@@ -289,7 +288,7 @@ def save_image(self, name: str, data: np.ndarray):
                 "name": name,
                 "data": data,
                 "dtype": "image",
-                "timestamp": datetime.datetime.now(),
+                "timestamp": clock.now(),
             }
             self.recorder.submit(image_entry)
 
@@ -422,8 +421,6 @@ def run(
             self.worker_comms.in_node_config(
                 state=self.state, eventbus=self.eventbus, logger=self.logger
             )
-            if self.worker_comms.worker_config:
-                config.update_defaults(self.worker_comms.worker_config)
         elif not self.state.logdir:
             self.state.logdir = pathlib.Path(tempfile.mktemp())
 
diff --git a/chimerapy/engine/node/poller_service.py b/chimerapy/engine/node/poller_service.py
index 4a5f466a..c9ea9bad 100644
--- a/chimerapy/engine/node/poller_service.py
+++ b/chimerapy/engine/node/poller_service.py
@@ -1,10 +1,10 @@
 import threading
 import logging
-import datetime
 from typing import Optional, Dict, Tuple, List
 
 import zmq
 
+from chimerapy.engine import clock
 from chimerapy.engine import _logger
 from ..states import NodeState
 from ..networking import Subscriber, DataChunk
@@ -149,7 +149,7 @@ def poll_inputs(self):
                 serial_data_chunk = s.recv()
                 data_chunk = DataChunk.from_bytes(serial_data_chunk)
                 meta = data_chunk.get("meta")
-                meta["value"]["received"] = datetime.datetime.now()
+                meta["value"]["received"] = clock.now()
                 data_chunk.update("meta", meta)
 
                 # Update the latest value
diff --git a/chimerapy/engine/node/processor_service.py b/chimerapy/engine/node/processor_service.py
index 56dcc208..db77e1c2 100644
--- a/chimerapy/engine/node/processor_service.py
+++ b/chimerapy/engine/node/processor_service.py
@@ -1,11 +1,11 @@
 import threading
 import traceback
-import datetime
 import logging
 import asyncio
 from typing import Dict, List, Optional, Callable, Coroutine, Any, Literal
 
 from chimerapy.engine import _logger
+from chimerapy.engine import clock
 from ..networking.client import Client
 from ..networking.enums import NODE_MESSAGE
 from ..networking import DataChunk
@@ -285,7 +285,7 @@ async def safe_step(self, data_chunks: Dict[str, DataChunk] = {}):
 
             # Add timestamp and step id to the DataChunk
             meta = output_data_chunk.get("meta")
-            meta["value"]["transmitted"] = datetime.datetime.now()
+            meta["value"]["transmitted"] = clock.now()
             output_data_chunk.update("meta", meta)
 
             # Send out the output to the OutputsHandler
diff --git a/chimerapy/engine/node/profiler_service.py b/chimerapy/engine/node/profiler_service.py
index 3e1804e8..0393dce6 100644
--- a/chimerapy/engine/node/profiler_service.py
+++ b/chimerapy/engine/node/profiler_service.py
@@ -1,7 +1,6 @@
 import os
 import pickle
 import logging
-import datetime
 from collections import deque
 from typing import Dict, Optional, Any, List
 
@@ -9,6 +8,7 @@
 from psutil import Process
 
 from chimerapy.engine import config
+from chimerapy.engine import clock
 from ..data_protocols import NodeDiagnostics
 from ..async_timer import AsyncTimer
 from ..networking.data_chunk import DataChunk
@@ -79,7 +79,7 @@ async def diagnostics_report(self):
             return None
 
         # Get the timestamp
-        timestamp = datetime.datetime.now().isoformat()
+        timestamp = clock.now().isoformat()
 
         # Get process-wide information
         memory = self.process.memory_info()
diff --git a/chimerapy/engine/node/worker_comms_service.py b/chimerapy/engine/node/worker_comms_service.py
index e32767f8..c993bd27 100644
--- a/chimerapy/engine/node/worker_comms_service.py
+++ b/chimerapy/engine/node/worker_comms_service.py
@@ -1,8 +1,11 @@
 import pathlib
 import logging
 import tempfile
+import datetime
 from typing import Dict, Optional
 
+from chimerapy.engine import config
+from chimerapy.engine import clock
 from ..networking import Client
 from ..states import NodeState
 from ..networking.enums import GENERAL_MESSAGE, WORKER_MESSAGE, NODE_MESSAGE
@@ -25,6 +28,7 @@ def __init__(
         host: str,
         port: int,
         node_config: NodeConfig,
+        manager_worker_timedelta: Optional[datetime.timedelta] = None,
         worker_logdir: Optional[pathlib.Path] = None,
         worker_config: Optional[Dict] = None,
         logging_level: int = logging.INFO,
@@ -42,6 +46,7 @@ def __init__(
         self.worker_config = worker_config
         self.logging_level = logging_level
         self.node_config = node_config
+        self.manager_worker_timedelta = manager_worker_timedelta
 
         # Optional
         self.state = state
@@ -77,6 +82,13 @@ def in_node_config(
         # Then add observers
         self.add_observers()
 
+        # Update config if possible
+        if self.worker_config:
+            config.update_defaults(self.worker_config)
+
+        # Set clock if possible
+        clock.sync()
+
     def add_observers(self):
         assert self.state and self.eventbus and self.logger
 
diff --git a/chimerapy/engine/worker/events.py b/chimerapy/engine/worker/events.py
index 65647889..af63c288 100644
--- a/chimerapy/engine/worker/events.py
+++ b/chimerapy/engine/worker/events.py
@@ -1,4 +1,5 @@
 import pathlib
+import datetime
 from dataclasses import dataclass, field
 from typing import Dict, Any
 from enum import Enum
@@ -13,6 +14,11 @@ class BroadcastEvent:
     data: Dict[str, Any] = field(default_factory=dict)
 
 
+@dataclass
+class ManagerWorkerTimeDeltaEvent:
+    manager_worker_timedelta: datetime.timedelta
+
+
 @dataclass
 class SendMessageEvent:
     client_id: str
diff --git a/chimerapy/engine/worker/http_client_service.py b/chimerapy/engine/worker/http_client_service.py
index 2641e3b4..3487d5c3 100644
--- a/chimerapy/engine/worker/http_client_service.py
+++ b/chimerapy/engine/worker/http_client_service.py
@@ -6,6 +6,7 @@
 import asyncio
 import pathlib
 import logging
+import datetime
 from typing import Optional, Literal, Union, Tuple, Dict
 
 import aiohttp
@@ -18,8 +19,8 @@
 from ..networking import Client
 from ..utils import get_ip_address
 from ..service import Service
-from ..eventbus import EventBus, TypedObserver
-from .events import SendArchiveEvent
+from ..eventbus import EventBus, TypedObserver, Event
+from .events import SendArchiveEvent, ManagerWorkerTimeDeltaEvent
 from .zeroconf_listener import ZeroconfListener
 
 
@@ -46,6 +47,7 @@ def __init__(
         self.manager_host = "0.0.0.0"
         self.manager_port = -1
         self.manager_url = ""
+        self.manager_datetime_now: Optional[datetime.datetime] = None
 
         # Specify observers
         self.observers: Dict[str, TypedObserver] = {
@@ -169,9 +171,26 @@ async def _async_connect_via_ip(
 
                 if resp.ok:
 
+                    # Track time
+                    worker_datetime_now = datetime.datetime.utcnow()
+
                     # Get JSON
                     data = await resp.json()
 
+                    # Compute the time difference
+                    manager_datetime_now = datetime.datetime.fromisoformat(
+                        data.get("manager_datetime_now", None)
+                    )
+                    manager_worker_timedelta = (
+                        worker_datetime_now - manager_datetime_now
+                    )
+
+                    event_data = ManagerWorkerTimeDeltaEvent(manager_worker_timedelta)
+                    await self.eventbus.asend(
+                        Event("manager_worker_timedelta", event_data)
+                    )
+
+                    # Update data
                     config.update_defaults(data.get("config", {}))
                     logs_push_info = data.get("logs_push_info", {})
 
diff --git a/chimerapy/engine/worker/node_handler_service.py b/chimerapy/engine/worker/node_handler_service.py
index db1b4cdc..45dfafc4 100644
--- a/chimerapy/engine/worker/node_handler_service.py
+++ b/chimerapy/engine/worker/node_handler_service.py
@@ -2,6 +2,7 @@
 import typing
 import warnings
 import logging
+import datetime
 from typing import Dict, Any, Union, Type, Optional
 
 if typing.TYPE_CHECKING:
@@ -31,6 +32,7 @@
     RegisteredMethodEvent,
     UpdateResultsEvent,
     UpdateGatherEvent,
+    ManagerWorkerTimeDeltaEvent,
 )
 
 
@@ -133,6 +135,7 @@ def __init__(
         self.eventbus = eventbus
         self.logger = logger
         self.logreceiver = logreceiver
+        self.manager_worker_timedelta: Optional[datetime.timedelta] = None
 
         # Containers
         self.node_controllers: Dict[str, NodeController] = {}
@@ -148,6 +151,12 @@ def __init__(
             "shutdown": TypedObserver(
                 "shutdown", on_asend=self.shutdown, handle_event="drop"
             ),
+            "manager_worker_timedelta": TypedObserver(
+                "manager_worker_timedelta",
+                ManagerWorkerTimeDeltaEvent,
+                on_asend=self.async_manager_worker_timedelta,
+                handle_event="unpack",
+            ),
             "create_node": TypedObserver(
                 "create_node",
                 CreateNodeEvent,
@@ -230,6 +239,11 @@ def update_results(self, node_id: str, results: Any):
         self.node_controllers[node_id].registered_method_results = results
         self.node_controllers[node_id].response = True
 
+    def async_manager_worker_timedelta(
+        self, manager_worker_timedelta: Optional[datetime.timedelta]
+    ):
+        self.manager_worker_timedelta = manager_worker_timedelta
+
     ###################################################################################
     ## Node Handling
     ###################################################################################
@@ -273,6 +287,7 @@ async def async_create_node(self, node_config: Union[NodeConfig, Dict]) -> bool:
                 name="worker",
                 host=self.state.ip,
                 port=self.state.port,
+                manager_worker_timedelta=self.manager_worker_timedelta,
                 worker_logdir=self.state.tempfolder,
                 worker_config=config.config,
                 node_config=node_config,
diff --git a/pyproject.toml b/pyproject.toml
index 0460a29a..df9194e0 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -34,7 +34,8 @@ dependencies = [
     'aiofiles',
     'zeroconf',
     'aioreactive',
-    'psutil'
+    'psutil',
+    'ntplib'
 ]
 
 [project.optional-dependencies]
diff --git a/test/manager/test_manager.py b/test/manager/test_manager.py
index f3136bf8..a88e2532 100644
--- a/test/manager/test_manager.py
+++ b/test/manager/test_manager.py
@@ -68,7 +68,8 @@ def test_sending_package(self, manager, _worker, config_graph):
             assert manager.workers[_worker.id].nodes[node_id].fsm != "NULL"
 
     # @pytest.mark.parametrize("context", ["multiprocessing", "threading"])
-    @pytest.mark.parametrize("context", ["threading"])
+    # @pytest.mark.parametrize("context", ["threading"])
+    @pytest.mark.parametrize("context", ["multiprocessing"])
     def test_manager_lifecycle(self, manager_with_worker, context):
         manager, worker = manager_with_worker
 
@@ -84,16 +85,9 @@ def test_manager_lifecycle(self, manager_with_worker, context):
         manager.commit_graph(graph, mapping, context=context).result(timeout=30)
 
         assert manager.start().result()
-
-        # time.sleep(3)
-
         assert manager.record().result()
 
-        # for i in range(50):
-        #     logger.debug(manager.state)
-        #     time.sleep(1)
-
-        time.sleep(20)
+        time.sleep(10)
 
         assert manager.stop().result()
         assert manager.collect().result()