fix plugin version

Author: hieheihei

instrumentation-genai/opentelemetry-instrumentation-dify/src/opentelemetry/instrumentation/dify/config.py

@@ -50,6 +50,7 @@ def is_version_supported():
     except:
         return False
 
+
 def is_wrapper_version_1():
     try:
         current_version = dify_config.CURRENT_VERSION
@@ -58,6 +59,14 @@ def is_wrapper_version_1():
     except:
         return False
 
+def is_wrapper_version_1_for_plugin():
+    try:
+        current_version = dify_config.CURRENT_VERSION
+        return (_compare_versions(current_version, "0.8.3") >= 0
+                and _compare_versions(current_version, "1.3.1") < 0)
+    except:
+        return False
+
 def is_wrapper_version_2():
     try:
         current_version = dify_config.CURRENT_VERSION
@@ -66,4 +75,13 @@ def is_wrapper_version_2():
     except:
         return False
 
+def is_wrapper_version_2_for_plugin():
+    try:
+        current_version = dify_config.CURRENT_VERSION
+        return (_compare_versions(current_version, "1.3.1") >= 0
+                and _compare_versions(current_version, "1.4.3") <= 0)
+    except:
+        return False
+
+
 

instrumentation-genai/opentelemetry-instrumentation-dify/src/opentelemetry/instrumentation/dify/wrapper.py

@@ -7,7 +7,8 @@
 from opentelemetry.instrumentation.dify.handler._rag_handler import ToolInvokeHandler, RetrieveHandler
 from opentelemetry.instrumentation.dify.handler._rag_handler import VectorSearchHandler
 from opentelemetry.instrumentation.dify.handler._rag_handler import FullTextSearchHandler
-from opentelemetry.instrumentation.dify.config import is_wrapper_version_1, is_wrapper_version_2
+from opentelemetry.instrumentation.dify.config import is_wrapper_version_1, is_wrapper_version_2, \
+    is_wrapper_version_2_for_plugin, is_wrapper_version_1_for_plugin
 
 _WORKFLOW_NODE_MODULE = "core.workflow.nodes.base.node"
 _RAG_RETRIEVAL_MODULE = "core.rag.retrieval.dataset_retrieval"
@@ -149,9 +150,9 @@ def set_workflow_cycle_wrapper_version_1(handler):
 
 
 def set_plugin_wrapper(tracer):
-    if is_wrapper_version_1():
+    if is_wrapper_version_1_for_plugin():
         set_plugin_wrapper_version_1(tracer)
-    elif is_wrapper_version_2():
+    elif is_wrapper_version_2_for_plugin():
         set_plugin_wrapper_version_2(tracer)
     else:
         return