Adds a fix to kill and remove a container if it still exists

runDocker.ts

@@ -14,24 +14,27 @@ const [, , command, jsonifiedArgs] = process.argv
 const docker = new Dockerode({ protocol: 'http' })
 
 let containerId = ''
-
 if (command === 'launch-ddb-local-docker-subprocess') {
   const { port } = JSON.parse(jsonifiedArgs)
+  let container: Container
+  try {
+    container = await createDdbContainer(port)
+  } catch (error) {
+    // Fix for Windows, containers exit, but do not get removed properly.
+    console.log('\nExisting container, removing and recreating')
+    const containers = await docker.listContainers({
+      limit: 1,
+      filters: '{"name": ["dynamodb-local"]}',
+    })
+    for (const existing of containers) {
+      if (existing.State !== 'exited') {
+        await docker.getContainer(existing.Id).kill()
+      }
+      await docker.getContainer(existing.Id).remove()
+    }
 
-  const container = await docker.createContainer({
-    Image: 'amazon/dynamodb-local:latest',
-    name: 'dynamodb-local',
-    Cmd: ['-jar', 'DynamoDBLocal.jar', '-sharedDb', '-dbPath', '/tmp/'],
-    ExposedPorts: {
-      '8000/tcp': {},
-    },
-
-    HostConfig: {
-      PortBindings: {
-        [`${port}/tcp`]: [{ HostIp: '0.0.0.0', HostPort: `${port}` }],
-      },
-    },
-  })
+    container = await createDdbContainer(port)
+  }
   containerId = container.id
   const stream = await container.attach({ stream: true, stderr: true })
   stream.pipe(process.stderr)
@@ -74,3 +77,19 @@ export const launchDocker: LauncherFunction = async ({ port, options }) => {
 export async function removeContainer(containerId: string) {
   await docker.getContainer(containerId).remove()
 }
+
+async function createDdbContainer(port: number) {
+  return await docker.createContainer({
+    Image: 'amazon/dynamodb-local:latest',
+    name: 'dynamodb-local',
+    Cmd: ['-jar', 'DynamoDBLocal.jar', '-sharedDb', '-dbPath', '/tmp/'],
+    ExposedPorts: {
+      '8000/tcp': {},
+    },
+    HostConfig: {
+      PortBindings: {
+        [`${port}/tcp`]: [{ HostIp: '0.0.0.0', HostPort: `${port}` }],
+      },
+    },
+  })
+}