@@ -87,7 +87,7 @@ export class HumanloopSpanExporter implements SpanExporter {
8787 *
8888 * @param spanId - The ID of the span that has been uploaded.
8989 */
90- private notifySpanUploaded ( spanId : string ) {
90+ private markSpanCompleted ( spanId : string ) {
9191 for ( const [ flowLogSpanId , flowChildrenSpanIds ] of this . prerequisites ) {
9292 if ( flowChildrenSpanIds . has ( spanId ) ) {
9393 flowChildrenSpanIds . delete ( spanId ) ;
@@ -161,7 +161,7 @@ export class HumanloopSpanExporter implements SpanExporter {
161161 } catch ( error ) {
162162 console . error ( `Error exporting prompt: ${ error } ` ) ;
163163 }
164- this . notifySpanUploaded ( span . spanContext ( ) . spanId ) ;
164+ this . markSpanCompleted ( span . spanContext ( ) . spanId ) ;
165165 }
166166
167167 private async exportTool ( span : ReadableSpan ) : Promise < void > {
@@ -190,7 +190,7 @@ export class HumanloopSpanExporter implements SpanExporter {
190190 } catch ( error ) {
191191 console . error ( `Error exporting tool: ${ error } ` ) ;
192192 }
193- this . notifySpanUploaded ( span . spanContext ( ) . spanId ) ;
193+ this . markSpanCompleted ( span . spanContext ( ) . spanId ) ;
194194 }
195195
196196 private async exportFlow ( span : ReadableSpan ) : Promise < void > {
@@ -233,6 +233,6 @@ export class HumanloopSpanExporter implements SpanExporter {
233233 } catch ( error ) {
234234 console . error ( "Error exporting flow: " , error , span . spanContext ( ) . spanId ) ;
235235 }
236- this . notifySpanUploaded ( span . spanContext ( ) . spanId ) ;
236+ this . markSpanCompleted ( span . spanContext ( ) . spanId ) ;
237237 }
238238}
0 commit comments