move opc_writer_sink block to enterprise

inference/core/workflows/core_steps/loader.py

@@ -221,7 +221,6 @@
     EmailNotificationBlockV1,
 )
 from inference.core.workflows.core_steps.sinks.local_file.v1 import LocalFileSinkBlockV1
-from inference.core.workflows.core_steps.sinks.opc_writer.v1 import OPCWriterSinkBlockV1
 from inference.core.workflows.core_steps.sinks.roboflow.custom_metadata.v1 import (
     RoboflowCustomMetadataBlockV1,
 )
@@ -541,7 +540,6 @@ def load_blocks() -> List[Type[WorkflowBlock]]:
         DataAggregatorBlockV1,
         CSVFormatterBlockV1,
         EmailNotificationBlockV1,
-        OPCWriterSinkBlockV1,
         LocalFileSinkBlockV1,
         TraceVisualizationBlockV1,
         ReferencePathVisualizationBlockV1,

inference/core/workflows/execution_engine/introspection/blocks_loader.py

@@ -9,13 +9,17 @@
 from packaging.specifiers import SpecifierSet
 from packaging.version import Version
 
+from inference.core.env import LAMBDA
 from inference.core.workflows.core_steps.loader import (
     KINDS_DESERIALIZERS,
     KINDS_SERIALIZERS,
     REGISTERED_INITIALIZERS,
     load_blocks,
     load_kinds,
 )
+from inference.enterprise.workflows.enterprise_steps.loader import (
+    load_enterprise_blocks,
+)
 from inference.core.workflows.errors import (
     PluginInterfaceError,
     PluginLoadingError,
@@ -150,6 +154,8 @@ def load_workflow_blocks(
 @lru_cache()
 def load_core_workflow_blocks() -> List[BlockSpecification]:
     core_blocks = load_blocks()
+    if not LAMBDA:
+        core_blocks.extend(load_enterprise_blocks())
     already_spotted_blocks = set()
     result = []
     for block in core_blocks:

inference/enterprise/workflows/enterprise_steps/loader.py

@@ -0,0 +1,10 @@
+from typing import List, Type
+
+from inference.enterprise.workflows.enterprise_steps.sinks.opc_writer.v1 import OPCWriterSinkBlockV1
+from inference.core.workflows.prototypes.block import WorkflowBlock
+
+
+def load_enterprise_blocks() -> List[Type[WorkflowBlock]]:
+    return [
+        OPCWriterSinkBlockV1,
+    ]

inference/core/workflows/core_steps/sinks/opc_writer/v1.py → inference/enterprise/workflows/enterprise_steps/sinks/opc_writer/v1.py

@@ -30,7 +30,7 @@
     WorkflowBlockManifest,
 )
 
-BLOCK_TYPE = "roboflow_core/opc_writer_sink@v1"
+BLOCK_TYPE = "roboflow_enterprise/opc_writer_sink@v1"
 LONG_DESCRIPTION = """
 The **OPC Writer** block enables sending a data from Workflow into OPC server
 by setting value of OPC object under OPC namespace.
@@ -66,6 +66,11 @@
 Sometimes it would be convenient to manually disable the **OPC Writer** block. This can be achieved by
 setting `disable_sink` flag to hold reference to Workflow input. With such setup, caller cat disable the sink
 by sending agreed input parameter.
+
+!!! warning "Cooldown limitations"
+    Current implementation of cooldown is limited to video processing - using this block in context of a 
+    Workflow that is run behind HTTP service (Roboflow Hosted API, Dedicated Deployment or self-hosted 
+    `inference` server) will have no effect with regards to cooldown timer.
 """
 
 QUERY_PARAMS_KIND = [

tests/workflows/integration_tests/execution/test_workflow_with_opc_writer.py

@@ -28,7 +28,7 @@
     ],
     "steps": [
         {
-            "type": "roboflow_core/opc_writer_sink@v1",
+            "type": "roboflow_enterprise/opc_writer_sink@v1",
             "name": "opc_writer",
             "url": "$inputs.opc_url",
             "namespace": "$inputs.opc_namespace",
@@ -169,7 +169,7 @@ def _opc_connect_and_read_value(
     workflow_definition=WORKFLOW_OPC_WRITER,
     workflow_name_in_app="opc_writer",
 )
-def test_workflow_with_classical_pattern_matching() -> None:
+def test_workflow_with_opc_writer_sink() -> None:
     # given
     loop = asyncio.new_event_loop()
     t = threading.Thread(target=start_loop, args=(loop,), daemon=True)