@@ -114,7 +114,9 @@ public DockerSessionFactory(
114
114
@ Override
115
115
public boolean test (Capabilities capabilities ) {
116
116
return stereotype .getCapabilityNames ().stream ()
117
- .map (name -> Objects .equals (stereotype .getCapability (name ), capabilities .getCapability (name )))
117
+ .map (
118
+ name ->
119
+ Objects .equals (stereotype .getCapability (name ), capabilities .getCapability (name )))
118
120
.reduce (Boolean ::logicalAnd )
119
121
.orElse (false );
120
122
}
@@ -170,7 +172,9 @@ public Optional<ActiveSession> apply(CreateSessionRequest sessionRequest) {
170
172
try {
171
173
result = new ProtocolHandshake ().createSession (client , command );
172
174
response = result .createResponse ();
173
- attributeMap .put (AttributeKey .DRIVER_RESPONSE .getKey (), EventAttribute .setValue (response .toString ()));
175
+ attributeMap .put (
176
+ AttributeKey .DRIVER_RESPONSE .getKey (),
177
+ EventAttribute .setValue (response .toString ()));
174
178
} catch (IOException | RuntimeException e ) {
175
179
span .setAttribute ("error" , true );
176
180
span .setStatus (Status .CANCELLED );
@@ -204,8 +208,12 @@ public Optional<ActiveSession> apply(CreateSessionRequest sessionRequest) {
204
208
Dialect downstream = sessionRequest .getDownstreamDialects ().contains (result .getDialect ()) ?
205
209
result .getDialect () :
206
210
W3C ;
207
- attributeMap .put (AttributeKey .DOWNSTREAM_DIALECT .getKey (), EventAttribute .setValue (downstream .toString ()));
208
- attributeMap .put (AttributeKey .DRIVER_RESPONSE .getKey (), EventAttribute .setValue (response .toString ()));
211
+ attributeMap .put (
212
+ AttributeKey .DOWNSTREAM_DIALECT .getKey (),
213
+ EventAttribute .setValue (downstream .toString ()));
214
+ attributeMap .put (
215
+ AttributeKey .DRIVER_RESPONSE .getKey (),
216
+ EventAttribute .setValue (response .toString ()));
209
217
210
218
span .addEvent ("Docker driver service created session" , attributeMap );
211
219
LOG .fine (String .format (
0 commit comments