Add roboflow_core/current_time@v1 Workflow block (#2410)

* Expose NumberInRange operator in workflow builder UI

The (Number) in range operator was already implemented in the evaluation
engine and BinaryStatement union but was not included in the introspection
export, making it invisible to the workflow builder UI.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

* Implement NumberInRange operator in query language backend

Adds the NumberInRange BinaryOperator class and its evaluation lambda so
the operator exposed in the workflow builder UI has a working backend.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

* Add roboflow_core/current_time@v1 Workflow block

New formatter block that outputs the current date/time for a user-selected
timezone. Inputs a curated IANA timezone (literal or selector, default UTC) and
returns a timezone-aware timestamp plus iso_string, date, and time strings.

Uses stdlib zoneinfo (backports.zoneinfo for py<3.9) and adds tzdata so the
timezone database is available on slim/Windows runtimes. Curated dropdown options
expose friendly UTC-offset labels via values_metadata. Registered in loader.py.
Includes unit tests and a full execution-engine integration test.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

* Remove zoneinfo backport dependency

---------

Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: patricknihranz

inference/core/workflows/core_steps/common/query_language/entities/operations.py

@@ -765,6 +765,21 @@ class NumberLowerEqual(BinaryOperator):
     type: Literal["(Number) <="]
 
 
+class NumberInRange(BinaryOperator):
+    model_config = ConfigDict(
+        json_schema_extra={
+            "description": "Checks if first value (number) is within the inclusive range given as second value (list of two numbers: [min, max])",
+            "operands_number": 2,
+            "operands_kinds": [
+                [INTEGER_KIND, FLOAT_KIND, FLOAT_ZERO_TO_ONE_KIND],
+                [LIST_OF_VALUES_KIND],
+            ],
+            "output_kind": [BOOLEAN_KIND],
+        },
+    )
+    type: Literal["(Number) in range"]
+
+
 class StringStartsWith(BinaryOperator):
     model_config = ConfigDict(
         json_schema_extra={
@@ -994,6 +1009,7 @@ class BinaryStatement(BaseModel):
             StringContains,
             StringEndsWith,
             StringStartsWith,
+            NumberInRange,
             NumberLowerEqual,
             NumberLower,
             NumberGreaterEqual,

inference/core/workflows/core_steps/common/query_language/evaluation_engine/core.py

@@ -34,6 +34,7 @@
     "(Number) >=": lambda a, b: a >= b,
     "(Number) <": lambda a, b: a < b,
     "(Number) <=": lambda a, b: a <= b,
+    "(Number) in range": lambda a, b: b[0] <= a <= b[1],
     "(String) startsWith": lambda a, b: a.startswith(b),
     "(String) endsWith": lambda a, b: a.endswith(b),
     "(String) contains": lambda a, b: b in a,

inference/core/workflows/core_steps/common/query_language/introspection/core.py

@@ -16,6 +16,7 @@
     NotEquals,
     NumberGreater,
     NumberGreaterEqual,
+    NumberInRange,
     NumberLower,
     NumberLowerEqual,
     OperationsChain,
@@ -104,6 +105,7 @@ def prepare_operators_descriptions() -> List[OperatorDescription]:
         NumberLower,
         NumberGreaterEqual,
         NumberGreater,
+        NumberInRange,
         NotEquals,
         Equals,
         Exists,

inference/core/workflows/core_steps/formatters/current_time/__init__.py

@@ -0,0 +1,159 @@
+from datetime import datetime
+from typing import Dict, List, Literal, Optional, Type, Union
+from zoneinfo import ZoneInfo, ZoneInfoNotFoundError
+
+from pydantic import ConfigDict, Field
+
+from inference.core.workflows.execution_engine.entities.base import OutputDefinition
+from inference.core.workflows.execution_engine.entities.types import (
+    STRING_KIND,
+    TIMESTAMP_KIND,
+    Selector,
+)
+from inference.core.workflows.prototypes.block import (
+    BlockResult,
+    WorkflowBlock,
+    WorkflowBlockManifest,
+)
+
+LONG_DESCRIPTION = """
+Output the current date and time for a given timezone.
+
+Provide one of the curated timezone options (for example `America/New_York`,
+`Europe/Berlin`, or `UTC`) and the block returns the current moment in that
+timezone. The block produces a `timestamp` (a timezone-aware `datetime` object you
+can pass to other blocks), along with ready-to-use `iso_string`, `date`, and
+`time` strings.
+
+The timezone may be a literal value typed into the block, or a reference to a workflow
+input or another step's output.
+"""
+
+SHORT_DESCRIPTION = "Output the current date and time for a given timezone."
+TIMEZONE_OPTIONS = (
+    ("Etc/GMT+12", "UTC-12 International Date Line West"),
+    ("Pacific/Pago_Pago", "UTC-11 Samoa Time (SST)"),
+    ("Pacific/Honolulu", "UTC-10 Hawaii-Aleutian Time (HST/HAST)"),
+    ("Pacific/Marquesas", "UTC-9:30 Marquesas Time (MART)"),
+    ("America/Anchorage", "UTC-9/-8 Alaska Time (AKST/AKDT)"),
+    ("Pacific/Gambier", "UTC-9 Gambier Time (GAMT)"),
+    ("America/Los_Angeles", "UTC-8/-7 Pacific Time (PST/PDT)"),
+    ("America/Denver", "UTC-7/-6 Mountain Time (MST/MDT)"),
+    ("America/Phoenix", "UTC-7 Mountain Standard Time (MST)"),
+    ("America/Chicago", "UTC-6/-5 Central Time (CST/CDT)"),
+    ("America/Mexico_City", "UTC-6 Mexico / Central America Time (CST)"),
+    ("America/New_York", "UTC-5/-4 Eastern Time (EST/EDT)"),
+    ("America/Bogota", "UTC-5 Colombia / Peru Time (COT/PET)"),
+    ("America/Halifax", "UTC-4/-3 Atlantic Time (AST/ADT)"),
+    ("America/Puerto_Rico", "UTC-4 Atlantic Standard Time (AST)"),
+    ("America/St_Johns", "UTC-3:30/-2:30 Newfoundland Time (NST/NDT)"),
+    ("America/Sao_Paulo", "UTC-3 Brasilia Time (BRT)"),
+    ("Atlantic/South_Georgia", "UTC-2 Mid-Atlantic Time (GST)"),
+    ("Atlantic/Azores", "UTC-1/+0 Azores Time (AZOT/AZOST)"),
+    ("Atlantic/Cape_Verde", "UTC-1 Cape Verde Time (CVT)"),
+    ("UTC", "UTC+0 Greenwich Mean Time (GMT/WET)"),
+    ("Europe/London", "UTC+0/+1 UK / Western European Time (GMT/BST/WET/WEST)"),
+    ("Europe/Berlin", "UTC+1/+2 Central European Time (CET/CEST)"),
+    ("Africa/Lagos", "UTC+1 West Africa Time (WAT)"),
+    ("Europe/Kyiv", "UTC+2/+3 Eastern European Time (EET/EEST)"),
+    ("Africa/Cairo", "UTC+2/+3 Egypt Time (EET/EEST)"),
+    ("Africa/Johannesburg", "UTC+2 South Africa Time (SAST)"),
+    ("Europe/Moscow", "UTC+3 Moscow Time (MSK)"),
+    ("Europe/Istanbul", "UTC+3 Turkey Time (TRT)"),
+    ("Africa/Nairobi", "UTC+3 East Africa Time (EAT)"),
+    ("Asia/Tehran", "UTC+3:30 Iran Time (IRST)"),
+    ("Asia/Dubai", "UTC+4 Gulf Time (GST)"),
+    ("Asia/Kabul", "UTC+4:30 Afghanistan Time (AFT)"),
+    ("Asia/Karachi", "UTC+5 Pakistan Time (PKT)"),
+    ("Asia/Kolkata", "UTC+5:30 India Time (IST)"),
+    ("Asia/Kathmandu", "UTC+5:45 Nepal Time (NPT)"),
+    ("Asia/Dhaka", "UTC+6 Bangladesh Time (BST)"),
+    ("Asia/Yangon", "UTC+6:30 Myanmar Time (MMT)"),
+    ("Asia/Bangkok", "UTC+7 Indochina Time (ICT)"),
+    ("Asia/Shanghai", "UTC+8 China / Western Australia Time (CST/AWST/PHT)"),
+    ("Australia/Eucla", "UTC+8:45 Central Western Australia Time (ACWST)"),
+    ("Asia/Tokyo", "UTC+9 Japan / Korea Time (JST/KST)"),
+    ("Australia/Darwin", "UTC+9:30 Australian Central Standard Time (ACST)"),
+    ("Australia/Adelaide", "UTC+9:30/+10:30 Australian Central Time (ACST/ACDT)"),
+    ("Australia/Sydney", "UTC+10/+11 Australian Eastern Time (AEST/AEDT)"),
+    ("Pacific/Port_Moresby", "UTC+10 Papua New Guinea Time (PGT)"),
+    ("Australia/Lord_Howe", "UTC+10:30/+11 Lord Howe Time (LHST/LHDT)"),
+    ("Pacific/Guadalcanal", "UTC+11 Solomon Islands Time (SBT)"),
+    ("Pacific/Norfolk", "UTC+11/+12 Norfolk Island Time (NFT/NFDT)"),
+    ("Pacific/Fiji", "UTC+12 Fiji Time (FJT)"),
+    ("Pacific/Auckland", "UTC+12/+13 New Zealand Time (NZST/NZDT)"),
+    ("Pacific/Chatham", "UTC+12:45/+13:45 Chatham Time (CHAST/CHADT)"),
+    ("Pacific/Tongatapu", "UTC+13 Tonga Time (TOT)"),
+    ("Pacific/Apia", "UTC+13 Samoa Time (WSST)"),
+    ("Pacific/Kiritimati", "UTC+14 Line Islands Time (LINT)"),
+)
+ALLOWED_TIMEZONES = tuple(timezone for timezone, _ in TIMEZONE_OPTIONS)
+ALLOWED_TIMEZONE_SET = frozenset(ALLOWED_TIMEZONES)
+TIMEZONE_METADATA: Dict[str, Dict[str, str]] = {
+    timezone: {"name": label} for timezone, label in TIMEZONE_OPTIONS
+}
+
+
+class BlockManifest(WorkflowBlockManifest):
+    model_config = ConfigDict(
+        json_schema_extra={
+            "name": "Current Time",
+            "version": "v1",
+            "short_description": SHORT_DESCRIPTION,
+            "long_description": LONG_DESCRIPTION,
+            "license": "Apache-2.0",
+            "block_type": "formatter",
+            "ui_manifest": {
+                "section": "advanced",
+                "icon": "far fa-clock",
+                "blockPriority": 10,
+            },
+        }
+    )
+    type: Literal["roboflow_core/current_time@v1"]
+    timezone: Union[Literal[ALLOWED_TIMEZONES], Selector(kind=[STRING_KIND])] = Field(  # type: ignore
+        default="UTC",
+        description="Curated IANA timezone name to report the current time in.",
+        examples=["UTC", "America/New_York", "Europe/Berlin", "$inputs.timezone"],
+        json_schema_extra={"values_metadata": TIMEZONE_METADATA},
+    )
+
+    @classmethod
+    def describe_outputs(cls) -> List[OutputDefinition]:
+        return [
+            OutputDefinition(name="timestamp", kind=[TIMESTAMP_KIND]),
+            OutputDefinition(name="iso_string", kind=[STRING_KIND]),
+            OutputDefinition(name="date", kind=[STRING_KIND]),
+            OutputDefinition(name="time", kind=[STRING_KIND]),
+        ]
+
+    @classmethod
+    def get_execution_engine_compatibility(cls) -> Optional[str]:
+        return ">=1.3.0,<2.0.0"
+
+
+class CurrentTimeBlockV1(WorkflowBlock):
+
+    @classmethod
+    def get_manifest(cls) -> Type[WorkflowBlockManifest]:
+        return BlockManifest
+
+    def run(self, timezone: str = "UTC") -> BlockResult:
+        if timezone not in ALLOWED_TIMEZONE_SET:
+            raise ValueError(
+                f"`roboflow_core/current_time@v1` received unsupported timezone '{timezone}'. "
+                "Provide one of the curated timezone options shown in the block dropdown."
+            )
+        try:
+            now = datetime.now(ZoneInfo(timezone))
+        except ZoneInfoNotFoundError as error:
+            raise ValueError(
+                f"`roboflow_core/current_time@v1` received unknown timezone '{timezone}'. "
+                "Provide one of the curated timezone options shown in the block dropdown."
+            ) from error
+        return {
+            "timestamp": now,
+            "iso_string": now.isoformat(),
+            "date": now.strftime("%Y-%m-%d"),
+            "time": now.strftime("%H:%M:%S"),
+        }

inference/core/workflows/core_steps/formatters/current_time/v1.py

@@ -153,6 +153,9 @@
     RateLimiterBlockV1,
 )
 from inference.core.workflows.core_steps.formatters.csv.v1 import CSVFormatterBlockV1
+from inference.core.workflows.core_steps.formatters.current_time.v1 import (
+    CurrentTimeBlockV1,
+)
 from inference.core.workflows.core_steps.formatters.expression.v1 import (
     ExpressionBlockV1,
 )
@@ -815,6 +818,7 @@ def load_blocks() -> List[Type[WorkflowBlock]]:
         DimensionCollapseBlockV1,
         DetectionsListRollUpBlockV1,
         FirstNonEmptyOrDefaultBlockV1,
+        CurrentTimeBlockV1,
         AnthropicClaudeBlockV1,
         AnthropicClaudeBlockV2,
         AnthropicClaudeBlockV3,

inference/core/workflows/core_steps/loader.py

@@ -4,9 +4,9 @@ APScheduler>=3.10.1,<4.0.0
 asyncua~=1.1.5
 cachetools<6.0.0
 cython~=3.0.0
-python-dotenv~=1.2.2
-fastapi>=0.133.0,<0.140  # 0.133+ dropped the starlette<1.0 cap; be careful with upper pin - fastapi might remove support for on_event
-starlette>=1.0.1  # CVE-2026-48710 (BadHost) — Host-header path-injection fix
+python-dotenv~=1.0.0
+tzdata>=2024.1
+fastapi>=0.100,<0.116  # be careful with upper pin - fastapi might remove support for on_event
 numpy>=2.0.0,<2.4.0
 opencv-python>=4.8.1.78,<=4.10.0.84
 opencv-contrib-python>=4.8.1.78,<=4.10.0.84  # Note: opencv-python considers this as a bad practice, but since our dependencies rely on both we pin both here

requirements/_requirements.txt

@@ -0,0 +1,60 @@
+import datetime
+
+from inference.core.env import WORKFLOWS_MAX_CONCURRENT_STEPS
+from inference.core.managers.base import ModelManager
+from inference.core.workflows.core_steps.common.entities import StepExecutionMode
+from inference.core.workflows.execution_engine.core import ExecutionEngine
+
+WORKFLOW_WITH_CURRENT_TIME = {
+    "version": "1.0",
+    "inputs": [
+        {
+            "type": "WorkflowParameter",
+            "name": "timezone",
+            "default_value": "UTC",
+        },
+    ],
+    "steps": [
+        {
+            "type": "roboflow_core/current_time@v1",
+            "name": "now",
+            "timezone": "$inputs.timezone",
+        },
+    ],
+    "outputs": [
+        {"type": "JsonField", "name": "timestamp", "selector": "$steps.now.timestamp"},
+        {"type": "JsonField", "name": "iso_string", "selector": "$steps.now.iso_string"},
+        {"type": "JsonField", "name": "date", "selector": "$steps.now.date"},
+        {"type": "JsonField", "name": "time", "selector": "$steps.now.time"},
+    ],
+}
+
+
+def test_current_time_workflow(model_manager: ModelManager) -> None:
+    # given
+    execution_engine = ExecutionEngine.init(
+        workflow_definition=WORKFLOW_WITH_CURRENT_TIME,
+        init_parameters={
+            "workflows_core.model_manager": model_manager,
+            "workflows_core.step_execution_mode": StepExecutionMode.LOCAL,
+        },
+        max_concurrent_steps=WORKFLOWS_MAX_CONCURRENT_STEPS,
+    )
+
+    # when
+    result = execution_engine.run(
+        runtime_parameters={"timezone": "America/New_York"}
+    )
+
+    # then
+    assert len(result) == 1, "Single image/parameter batch expected"
+    row = result[0]
+    assert set(row.keys()) == {"timestamp", "iso_string", "date", "time"}
+    assert isinstance(row["timestamp"], datetime.datetime)
+    assert row["timestamp"].tzinfo is not None, "Timestamp must be timezone-aware"
+    assert str(row["timestamp"].tzinfo) == "America/New_York"
+    # derived strings agree with the datetime object
+    assert row["iso_string"] == row["timestamp"].isoformat()
+    assert row["iso_string"].startswith(row["date"])
+    assert row["date"] == row["timestamp"].strftime("%Y-%m-%d")
+    assert row["time"] == row["timestamp"].strftime("%H:%M:%S")