@@ -1273,7 +1273,7 @@ func (sc *syncContext) runTasks(tasks syncTasks, dryRun bool) runState {
1273
1273
ss .Go (func (state runState ) runState {
1274
1274
logCtx := sc .log .WithValues ("dryRun" , dryRun , "task" , t )
1275
1275
logCtx .V (1 ).Info ("Pruning" )
1276
- span := sc .syncTracer . StartSpanFromTraceParent ("pruneObject" , sc . syncTraceID , sc . syncTraceRootSpanID )
1276
+ span := sc .createSpan ("pruneObject" , dryRun )
1277
1277
defer span .Finish ()
1278
1278
result , message := sc .pruneObject (t .liveObj , sc .prune , dryRun )
1279
1279
if result == common .ResultCodeSyncFailed {
@@ -1303,7 +1303,7 @@ func (sc *syncContext) runTasks(tasks syncTasks, dryRun bool) runState {
1303
1303
ss .Go (func (state runState ) runState {
1304
1304
sc .log .WithValues ("dryRun" , dryRun , "task" , t ).V (1 ).Info ("Deleting" )
1305
1305
if ! dryRun {
1306
- span := sc .syncTracer . StartSpanFromTraceParent ("hooksDeletion" , sc . syncTraceID , sc . syncTraceRootSpanID )
1306
+ span := sc .createSpan ("hooksDeletion" , dryRun )
1307
1307
defer span .Finish ()
1308
1308
err := sc .deleteResource (t )
1309
1309
message := "deleted"
@@ -1381,7 +1381,7 @@ func (sc *syncContext) processCreateTasks(state runState, tasks syncTasks, dryRu
1381
1381
logCtx := sc .log .WithValues ("dryRun" , dryRun , "task" , t )
1382
1382
logCtx .V (1 ).Info ("Applying" )
1383
1383
validate := sc .validate && ! resourceutil .HasAnnotationOption (t .targetObj , common .AnnotationSyncOptions , common .SyncOptionsDisableValidation )
1384
- span := sc .syncTracer . StartSpanFromTraceParent ("applyObject" , sc . syncTraceID , sc . syncTraceRootSpanID )
1384
+ span := sc .createSpan ("applyObject" , dryRun )
1385
1385
defer span .Finish ()
1386
1386
result , message := sc .applyObject (t , dryRun , validate )
1387
1387
if result == common .ResultCodeSyncFailed {
0 commit comments