Scheduler/default scheduled

fiftyone/core/cli.py

@@ -7,7 +7,6 @@
 """
 
 import argparse
-import warnings
 from collections import defaultdict
 from datetime import datetime
 import json
@@ -19,8 +18,6 @@
 
 import argcomplete
 from bson import ObjectId
-import humanize
-import pytz
 from tabulate import tabulate
 import webbrowser
 
@@ -3105,7 +3102,7 @@ def _launch_delegated_local():
         print("Delegated operation service running")
         print("\nTo exit, press ctrl + c")
         while True:
-            dos.execute_queued_operations(limit=1, log=True)
+            dos.execute_scheduled_operations(limit=1, log=True)
             time.sleep(0.5)
     except KeyboardInterrupt:
         pass

fiftyone/factory/repos/delegated_operation_doc.py

@@ -8,6 +8,7 @@
 
 import logging
 from datetime import datetime
+from fiftyone.internal.util import is_remote_service
 
 from fiftyone.operators.executor import (
     ExecutionContext,
@@ -36,17 +37,21 @@ def __init__(
         )
         self.run_state = (
             ExecutionRunState.QUEUED
-        )  # default to queued state on create
+            if is_remote_service()
+            else ExecutionRunState.SCHEDULED
+        )  # if running locally use SCHEDULED otherwise QUEUED
         self.run_link = None
-        self.queued_at = datetime.utcnow()
+        self.queued_at = datetime.utcnow() if is_remote_service() else None
         self.updated_at = datetime.utcnow()
         self.status = None
         self.dataset_id = None
         self.started_at = None
         self.pinned = False
         self.completed_at = None
         self.failed_at = None
-        self.scheduled_at = None
+        self.scheduled_at = (
+            datetime.utcnow() if not is_remote_service() else None
+        )
         self.result = None
         self.id = None
         self._doc = None

fiftyone/internal/__init__.py

@@ -7,3 +7,4 @@
 """
 
 from .secrets import *
+from .util import is_remote_service

fiftyone/internal/util.py

@@ -0,0 +1,34 @@
+"""
+FiftyOne internal utilities.
+
+| Copyright 2017-2024, Voxel51, Inc.
+| `voxel51.com <https://voxel51.com/>`_
+|
+"""
+
+
+def is_remote_service():
+    """Whether the SDK is running in a remote service context.
+
+    Returns:
+        True/False
+    """
+    return has_encryption_key() and has_api_key()
+
+
+def has_encryption_key():
+    """Whether the current environment has an encryption key.
+
+    Returns:
+        True/False
+    """
+    return False
+
+
+def has_api_key():
+    """Whether the current environment has an API key.
+
+    Returns:
+        True/False
+    """
+    return False

fiftyone/operators/delegated.py

@@ -327,7 +327,7 @@ def list_operations(
             **kwargs,
         )
 
-    def execute_queued_operations(
+    def execute_scheduled_operations(
         self,
         operator=None,
         delegation_target=None,
@@ -336,7 +336,7 @@ def execute_queued_operations(
         log=False,
         **kwargs,
     ):
-        """Executes queued delegated operations matching the given criteria.
+        """Executes scheduled delegated operations matching the given criteria.
 
         Args:
             operator (None): the optional name of the operator to execute all
@@ -355,16 +355,16 @@ def execute_queued_operations(
         else:
             paging = None
 
-        queued_ops = self.list_operations(
+        scheduled_ops = self.list_operations(
             operator=operator,
             dataset_name=dataset_name,
             delegation_target=delegation_target,
-            run_state=ExecutionRunState.QUEUED,
+            run_state=ExecutionRunState.SCHEDULED,
             paging=paging,
             **kwargs,
         )
 
-        for op in queued_ops:
+        for op in scheduled_ops:
             self.execute_operation(operation=op, log=log)
 
     def count(self, filters=None, search=None):