add internal host to batch to mirror sfn behavior (#4748)
This commit is contained in:
		
							parent
							
								
									01ae8c01a6
								
							
						
					
					
						commit
						99ea1d07c5
					
				@ -7,6 +7,7 @@ import logging
 | 
				
			|||||||
import docker
 | 
					import docker
 | 
				
			||||||
import threading
 | 
					import threading
 | 
				
			||||||
import dateutil.parser
 | 
					import dateutil.parser
 | 
				
			||||||
 | 
					from sys import platform
 | 
				
			||||||
 | 
					
 | 
				
			||||||
from moto.core import BaseBackend, BaseModel, CloudFormationModel
 | 
					from moto.core import BaseBackend, BaseModel, CloudFormationModel
 | 
				
			||||||
from moto.iam import iam_backends
 | 
					from moto.iam import iam_backends
 | 
				
			||||||
@ -553,6 +554,14 @@ class Job(threading.Thread, BaseModel, DockerModel):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
            self.job_started_at = datetime.datetime.now()
 | 
					            self.job_started_at = datetime.datetime.now()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					            # add host.docker.internal host on linux to emulate Mac + Windows behavior
 | 
				
			||||||
 | 
					            #   for communication with other mock AWS services running on localhost
 | 
				
			||||||
 | 
					            extra_hosts = (
 | 
				
			||||||
 | 
					                {"host.docker.internal": "host-gateway",}
 | 
				
			||||||
 | 
					                if platform == "linux" or platform == "linux2"
 | 
				
			||||||
 | 
					                else {}
 | 
				
			||||||
 | 
					            )
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            log_config = docker.types.LogConfig(type=docker.types.LogConfig.types.JSON)
 | 
					            log_config = docker.types.LogConfig(type=docker.types.LogConfig.types.JSON)
 | 
				
			||||||
            self.job_state = "STARTING"
 | 
					            self.job_state = "STARTING"
 | 
				
			||||||
            container = self.docker_client.containers.run(
 | 
					            container = self.docker_client.containers.run(
 | 
				
			||||||
@ -564,6 +573,7 @@ class Job(threading.Thread, BaseModel, DockerModel):
 | 
				
			|||||||
                environment=environment,
 | 
					                environment=environment,
 | 
				
			||||||
                mounts=mounts,
 | 
					                mounts=mounts,
 | 
				
			||||||
                privileged=privileged,
 | 
					                privileged=privileged,
 | 
				
			||||||
 | 
					                extra_hosts=extra_hosts,
 | 
				
			||||||
            )
 | 
					            )
 | 
				
			||||||
            self.job_state = "RUNNING"
 | 
					            self.job_state = "RUNNING"
 | 
				
			||||||
            try:
 | 
					            try:
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user