@@ -2,7 +2,8 @@ import { env } from "~/env.server";
22import { AuthenticatedEnvironment } from "~/services/apiAuth.server" ;
33import { logger } from "~/services/logger.server" ;
44import { singleton } from "~/utils/singleton" ;
5- import { startActiveSpan } from "./tracer.server" ;
5+ import { tracer } from "~/v3/tracer.server" ;
6+ import { startSpan } from "~/v3/tracing.server" ;
67import { IOPacket } from "@trigger.dev/core/v3" ;
78import { ObjectStoreClient , type ObjectStoreClientConfig } from "./objectStoreClient.server" ;
89
@@ -128,7 +129,7 @@ export async function uploadPacketToObjectStore(
128129 environment : AuthenticatedEnvironment ,
129130 storageProtocol ?: string
130131) : Promise < string > {
131- return await startActiveSpan ( "uploadPacketToObjectStore()" , async ( span ) => {
132+ return await startSpan ( tracer , "uploadPacketToObjectStore()" , async ( span ) => {
132133 const protocol = storageProtocol || env . OBJECT_STORE_DEFAULT_PROTOCOL ;
133134 const client = getObjectStoreClient ( protocol ) ;
134135
@@ -162,7 +163,7 @@ export async function downloadPacketFromObjectStore(
162163 return packet ;
163164 }
164165
165- return await startActiveSpan ( "downloadPacketFromObjectStore()" , async ( span ) => {
166+ return await startSpan ( tracer , "downloadPacketFromObjectStore()" , async ( span ) => {
166167 // There shouldn't be an offloaded packet with undefined data…
167168 if ( ! packet . data ) {
168169 logger . error ( "Object store packet has undefined data" , { packet, environment } ) ;
0 commit comments