@@ -712,7 +712,7 @@ async def _remove_script(self, sal_index):
             else:
                 await self._update_queue()
 
-    def _log_message_callback(self, data):
+    async def _log_message_callback(self, data):
         """Print Script logMessage data to stdout.
 
         To use: if self.verbose is true then set this as a callback
 
@@ -167,7 +167,7 @@ async def run_one_script(index, script, config, loglevel=None):
         )
         await remote.start_task
 
-        def log_callback(data):
+        async def log_callback(data):
             iso_time = datetime.datetime.now().time().isoformat(timespec="milliseconds")
             print(f"{iso_time} {logging.getLevelName(data.level)}: {data.message}")
 
 
@@ -148,7 +148,7 @@ async def script_heartbeat_monitor(self):
                 f"heartbeat not seen in {HEARTBEAT_ALARM_INTERVAL} seconds"
             )
 
-    def script_log_message(self, data):
+    async def script_log_message(self, data):
         exception_str = (
             (
                 f", traceback={data.traceback}, "
@@ -165,7 +165,7 @@ def script_log_message(self, data):
             f"message={data.message}{exception_str}"
         )
 
-    def script_state(self, data):
+    async def script_state(self, data):
         try:
             state = ScriptState(data.state)
         except ValueError:
@@ -176,7 +176,7 @@ def script_state(self, data):
             f"state={state.name}{reason}, lastCheckpoint={data.lastCheckpoint}"
         )
 
-    def script_heartbeat(self, data):
+    async def script_heartbeat(self, data):
         if data.salIndex != self._script_to_monitor:
             # A heartbeat from the wrong script.
             return
 
@@ -175,7 +175,7 @@ async def test_run_command_line(self):
             # (e.g. [1, 1, 2, 2, 1, 1] becomes [1, 2, 1]
             states_seen = []
 
-            def state_callback(data):
+            async def state_callback(data):
                 nonlocal states_seen
                 state = ScriptState(data.state)
                 if not states_seen or state != states_seen[-1]:
Original file line number	Diff line number	Diff line change
`@@ -167,7 +167,7 @@ async def run_one_script(index, script, config, loglevel=None):`
`167`	`167`	`)`
`168`	`168`	`await remote.start_task`
`169`	`169`
`170`		`- def log_callback(data):`
	`170`	`+ async def log_callback(data):`
`171`	`171`	`iso_time = datetime.datetime.now().time().isoformat(timespec="milliseconds")`
`172`	`172`	`print(f"{iso_time} {logging.getLevelName(data.level)}: {data.message}")`
`173`	`173`
Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,7 @@ async def script_heartbeat_monitor(self):`
`148`	`148`	`f"heartbeat not seen in {HEARTBEAT_ALARM_INTERVAL} seconds"`
`149`	`149`	`)`
`150`	`150`
`151`		`- def script_log_message(self, data):`
	`151`	`+ async def script_log_message(self, data):`
`152`	`152`	`exception_str = (`
`153`	`153`	`(`
`154`	`154`	`f", traceback={data.traceback}, "`
`@@ -165,7 +165,7 @@ def script_log_message(self, data):`
`165`	`165`	`f"message={data.message}{exception_str}"`
`166`	`166`	`)`
`167`	`167`
`168`		`- def script_state(self, data):`
	`168`	`+ async def script_state(self, data):`
`169`	`169`	`try:`
`170`	`170`	`state = ScriptState(data.state)`
`171`	`171`	`except ValueError:`
`@@ -176,7 +176,7 @@ def script_state(self, data):`
`176`	`176`	`f"state={state.name}{reason}, lastCheckpoint={data.lastCheckpoint}"`
`177`	`177`	`)`
`178`	`178`
`179`		`- def script_heartbeat(self, data):`
	`179`	`+ async def script_heartbeat(self, data):`
`180`	`180`	`if data.salIndex != self._script_to_monitor:`
`181`	`181`	`# A heartbeat from the wrong script.`
`182`	`182`	`return`