diff --git a/scos_actions/actions/acquire_sea_data_product.py b/scos_actions/actions/acquire_sea_data_product.py index 03e3f764..bd2a8d82 100644 --- a/scos_actions/actions/acquire_sea_data_product.py +++ b/scos_actions/actions/acquire_sea_data_product.py @@ -23,6 +23,7 @@ import logging import lzma import platform +import ray import sys from enum import EnumMeta from time import perf_counter @@ -505,7 +506,6 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int): action_start_tic = perf_counter() # Ray should have already been initialized within scos-sensor, # but check and initialize just in case. - import ray if not ray.is_initialized(): logger.info("Initializing ray.")