Skip to content

Commit 4f936a0

Browse files
committed
fix: decoupling docker api version using APIVersionNegotiation
1 parent 18fd477 commit 4f936a0

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

core/cmd_connection/docker_attach.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,7 @@ func (d *DockerAttachConnection) Prepare(ctx context.Context, task *config.Task)
9393
func (d *DockerAttachConnection) Connect() error {
9494
cli, err := client.NewClientWithOpts(
9595
client.WithHost(d.conn.DockerConnection),
96+
client.WithAPIVersionNegotiation(),
9697
)
9798
if err != nil {
9899
return err

core/cmd_connection/docker_create.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,7 @@ func (d *DockerCreateConnection) Prepare(ctx context.Context, task *config.Task)
111111
func (d *DockerCreateConnection) Connect() error {
112112
cli, err := client.NewClientWithOpts(
113113
client.WithHost(d.conn.DockerConnection),
114+
client.WithAPIVersionNegotiation(),
114115
)
115116
if err != nil {
116117
return err

core/event/docker.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,7 @@ func (de *DockerEvent) BuildTickChannel() abstraction.EventChannel {
8383

8484
cli, err := client.NewClientWithOpts(
8585
client.WithHost(de.connection),
86+
client.WithAPIVersionNegotiation(),
8687
)
8788
if err != nil {
8889
de.log.Warn("failed to connect to docker: ", err)

0 commit comments

Comments
 (0)