File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
airbyte-commons-server/src/main/java/io/airbyte/commons/server/handlers Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change 11
11
import io .airbyte .commons .server .errors .SyncIsRunningException ;
12
12
import io .airbyte .config .StateWrapper ;
13
13
import io .airbyte .config .persistence .StatePersistence ;
14
+ import io .airbyte .metrics .lib .ApmTraceUtils ;
15
+ import io .airbyte .metrics .lib .MetricTags ;
14
16
import jakarta .inject .Singleton ;
15
17
import java .io .IOException ;
18
+ import java .util .Map ;
16
19
import java .util .Optional ;
17
20
import java .util .UUID ;
18
21
@@ -38,6 +41,7 @@ public ConnectionState getState(final ConnectionIdRequestBody connectionIdReques
38
41
39
42
public ConnectionState createOrUpdateState (final ConnectionStateCreateOrUpdate connectionStateCreateOrUpdate ) throws IOException {
40
43
final UUID connectionId = connectionStateCreateOrUpdate .getConnectionId ();
44
+ ApmTraceUtils .addTagsToTrace (Map .of (MetricTags .CONNECTION_ID , connectionId ));
41
45
42
46
final StateWrapper convertedCreateOrUpdate = StateConverter .toInternal (connectionStateCreateOrUpdate .getConnectionState ());
43
47
statePersistence .updateOrCreateState (connectionId , convertedCreateOrUpdate );
You can’t perform that action at this time.
0 commit comments