Skip to content
Merged
33 changes: 18 additions & 15 deletions src/langtrace_python_sdk/instrumentation/crewai/instrumentation.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,21 +33,24 @@ def _instrument(self, **kwargs):
tracer_provider = kwargs.get("tracer_provider")
tracer = get_tracer(__name__, "", tracer_provider)
version = v("crewai")
_W(
"crewai.crew",
"Crew.kickoff",
patch_crew("Crew.kickoff", version, tracer),
)
_W(
"crewai.agent",
"Agent.execute_task",
patch_crew("Agent.execute_task", version, tracer),
)
_W(
"crewai.task",
"Task.execute",
patch_crew("Task.execute", version, tracer),
)
try:
_W(
"crewai.crew",
"Crew.kickoff",
patch_crew("Crew.kickoff", version, tracer),
)
_W(
"crewai.agent",
"Agent.execute_task",
patch_crew("Agent.execute_task", version, tracer),
)
_W(
"crewai.task",
"Task.execute",
patch_crew("Task.execute", version, tracer),
)
except Exception as e:
pass

def _uninstrument(self, **kwargs):
pass
1 change: 1 addition & 0 deletions src/langtrace_python_sdk/utils/llm.py
Original file line number Diff line number Diff line change
Expand Up @@ -88,6 +88,7 @@ def get_langtrace_attributes(version, service_provider, vendor_type="llm"):
SpanAttributes.LANGTRACE_SERVICE_VERSION: version,
SpanAttributes.LANGTRACE_SERVICE_NAME: service_provider,
SpanAttributes.LANGTRACE_SERVICE_TYPE: vendor_type,
SpanAttributes.LLM_SYSTEM: service_provider,
}


Expand Down
2 changes: 1 addition & 1 deletion src/langtrace_python_sdk/version.py
Original file line number Diff line number Diff line change
@@ -1 +1 @@
__version__ = "2.2.5"
__version__ = "2.2.6"