123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980 |
- from __future__ import absolute_import
- from __future__ import unicode_literals
- import json
- import os
- import random
- import shutil
- import tempfile
- import py
- import pytest
- from docker.errors import APIError
- from docker.errors import NotFound
- from .. import mock
- from ..helpers import build_config as load_config
- from ..helpers import create_host_file
- from .testcases import DockerClientTestCase
- from .testcases import SWARM_SKIP_CONTAINERS_ALL
- from compose.config import config
- from compose.config import ConfigurationError
- from compose.config import types
- from compose.config.types import VolumeFromSpec
- from compose.config.types import VolumeSpec
- from compose.const import COMPOSEFILE_V2_0 as V2_0
- from compose.const import COMPOSEFILE_V2_1 as V2_1
- from compose.const import COMPOSEFILE_V2_2 as V2_2
- from compose.const import COMPOSEFILE_V2_3 as V2_3
- from compose.const import COMPOSEFILE_V3_1 as V3_1
- from compose.const import LABEL_PROJECT
- from compose.const import LABEL_SERVICE
- from compose.container import Container
- from compose.errors import HealthCheckFailed
- from compose.errors import NoHealthCheckConfigured
- from compose.project import Project
- from compose.project import ProjectError
- from compose.service import ConvergenceStrategy
- from tests.integration.testcases import if_runtime_available
- from tests.integration.testcases import is_cluster
- from tests.integration.testcases import no_cluster
- from tests.integration.testcases import v2_1_only
- from tests.integration.testcases import v2_2_only
- from tests.integration.testcases import v2_3_only
- from tests.integration.testcases import v2_only
- from tests.integration.testcases import v3_only
- def build_config(**kwargs):
- return config.Config(
- version=kwargs.get('version'),
- services=kwargs.get('services'),
- volumes=kwargs.get('volumes'),
- networks=kwargs.get('networks'),
- secrets=kwargs.get('secrets'),
- configs=kwargs.get('configs'),
- )
- class ProjectTest(DockerClientTestCase):
- def test_containers(self):
- web = self.create_service('web')
- db = self.create_service('db')
- project = Project('composetest', [web, db], self.client)
- project.up()
- containers = project.containers()
- assert len(containers) == 2
- @pytest.mark.skipif(SWARM_SKIP_CONTAINERS_ALL, reason='Swarm /containers/json bug')
- def test_containers_stopped(self):
- web = self.create_service('web')
- db = self.create_service('db')
- project = Project('composetest', [web, db], self.client)
- project.up()
- assert len(project.containers()) == 2
- assert len(project.containers(stopped=True)) == 2
- project.stop()
- assert len(project.containers()) == 0
- assert len(project.containers(stopped=True)) == 2
- def test_containers_with_service_names(self):
- web = self.create_service('web')
- db = self.create_service('db')
- project = Project('composetest', [web, db], self.client)
- project.up()
- containers = project.containers(['web'])
- assert len(containers) == 1
- assert containers[0].name.startswith('composetest_web_')
- def test_containers_with_extra_service(self):
- web = self.create_service('web')
- web_1 = web.create_container()
- db = self.create_service('db')
- db_1 = db.create_container()
- self.create_service('extra').create_container()
- project = Project('composetest', [web, db], self.client)
- assert set(project.containers(stopped=True)) == set([web_1, db_1])
- def test_volumes_from_service(self):
- project = Project.from_config(
- name='composetest',
- config_data=load_config({
- 'data': {
- 'image': 'busybox:latest',
- 'volumes': ['/var/data'],
- },
- 'db': {
- 'image': 'busybox:latest',
- 'volumes_from': ['data'],
- },
- }),
- client=self.client,
- )
- db = project.get_service('db')
- data = project.get_service('data')
- assert db.volumes_from == [VolumeFromSpec(data, 'rw', 'service')]
- def test_volumes_from_container(self):
- data_container = Container.create(
- self.client,
- image='busybox:latest',
- volumes=['/var/data'],
- name='composetest_data_container',
- labels={LABEL_PROJECT: 'composetest'},
- host_config={},
- )
- project = Project.from_config(
- name='composetest',
- config_data=load_config({
- 'db': {
- 'image': 'busybox:latest',
- 'volumes_from': ['composetest_data_container'],
- },
- }),
- client=self.client,
- )
- db = project.get_service('db')
- assert db._get_volumes_from() == [data_container.id + ':rw']
- @v2_only()
- @no_cluster('container networks not supported in Swarm')
- def test_network_mode_from_service(self):
- project = Project.from_config(
- name='composetest',
- client=self.client,
- config_data=load_config({
- 'version': str(V2_0),
- 'services': {
- 'net': {
- 'image': 'busybox:latest',
- 'command': ["top"]
- },
- 'web': {
- 'image': 'busybox:latest',
- 'network_mode': 'service:net',
- 'command': ["top"]
- },
- },
- }),
- )
- project.up()
- web = project.get_service('web')
- net = project.get_service('net')
- assert web.network_mode.mode == 'container:' + net.containers()[0].id
- @v2_only()
- @no_cluster('container networks not supported in Swarm')
- def test_network_mode_from_container(self):
- def get_project():
- return Project.from_config(
- name='composetest',
- config_data=load_config({
- 'version': str(V2_0),
- 'services': {
- 'web': {
- 'image': 'busybox:latest',
- 'network_mode': 'container:composetest_net_container'
- },
- },
- }),
- client=self.client,
- )
- with pytest.raises(ConfigurationError) as excinfo:
- get_project()
- assert "container 'composetest_net_container' which does not exist" in excinfo.exconly()
- net_container = Container.create(
- self.client,
- image='busybox:latest',
- name='composetest_net_container',
- command='top',
- labels={LABEL_PROJECT: 'composetest'},
- host_config={},
- )
- net_container.start()
- project = get_project()
- project.up()
- web = project.get_service('web')
- assert web.network_mode.mode == 'container:' + net_container.id
- @no_cluster('container networks not supported in Swarm')
- def test_net_from_service_v1(self):
- project = Project.from_config(
- name='composetest',
- config_data=load_config({
- 'net': {
- 'image': 'busybox:latest',
- 'command': ["top"]
- },
- 'web': {
- 'image': 'busybox:latest',
- 'net': 'container:net',
- 'command': ["top"]
- },
- }),
- client=self.client,
- )
- project.up()
- web = project.get_service('web')
- net = project.get_service('net')
- assert web.network_mode.mode == 'container:' + net.containers()[0].id
- @no_cluster('container networks not supported in Swarm')
- def test_net_from_container_v1(self):
- def get_project():
- return Project.from_config(
- name='composetest',
- config_data=load_config({
- 'web': {
- 'image': 'busybox:latest',
- 'net': 'container:composetest_net_container'
- },
- }),
- client=self.client,
- )
- with pytest.raises(ConfigurationError) as excinfo:
- get_project()
- assert "container 'composetest_net_container' which does not exist" in excinfo.exconly()
- net_container = Container.create(
- self.client,
- image='busybox:latest',
- name='composetest_net_container',
- command='top',
- labels={LABEL_PROJECT: 'composetest'},
- host_config={},
- )
- net_container.start()
- project = get_project()
- project.up()
- web = project.get_service('web')
- assert web.network_mode.mode == 'container:' + net_container.id
- def test_start_pause_unpause_stop_kill_remove(self):
- web = self.create_service('web')
- db = self.create_service('db')
- project = Project('composetest', [web, db], self.client)
- project.start()
- assert len(web.containers()) == 0
- assert len(db.containers()) == 0
- web_container_1 = web.create_container()
- web_container_2 = web.create_container()
- db_container = db.create_container()
- project.start(service_names=['web'])
- assert set(c.name for c in project.containers() if c.is_running) == set(
- [web_container_1.name, web_container_2.name]
- )
- project.start()
- assert set(c.name for c in project.containers() if c.is_running) == set(
- [web_container_1.name, web_container_2.name, db_container.name]
- )
- project.pause(service_names=['web'])
- assert set([c.name for c in project.containers() if c.is_paused]) == set(
- [web_container_1.name, web_container_2.name]
- )
- project.pause()
- assert set([c.name for c in project.containers() if c.is_paused]) == set(
- [web_container_1.name, web_container_2.name, db_container.name]
- )
- project.unpause(service_names=['db'])
- assert len([c.name for c in project.containers() if c.is_paused]) == 2
- project.unpause()
- assert len([c.name for c in project.containers() if c.is_paused]) == 0
- project.stop(service_names=['web'], timeout=1)
- assert set(c.name for c in project.containers() if c.is_running) == set([db_container.name])
- project.kill(service_names=['db'])
- assert len([c for c in project.containers() if c.is_running]) == 0
- assert len(project.containers(stopped=True)) == 3
- project.remove_stopped(service_names=['web'])
- assert len(project.containers(stopped=True)) == 1
- project.remove_stopped()
- assert len(project.containers(stopped=True)) == 0
- def test_create(self):
- web = self.create_service('web')
- db = self.create_service('db', volumes=[VolumeSpec.parse('/var/db')])
- project = Project('composetest', [web, db], self.client)
- project.create(['db'])
- containers = project.containers(stopped=True)
- assert len(containers) == 1
- assert not containers[0].is_running
- db_containers = db.containers(stopped=True)
- assert len(db_containers) == 1
- assert not db_containers[0].is_running
- assert len(web.containers(stopped=True)) == 0
- def test_create_twice(self):
- web = self.create_service('web')
- db = self.create_service('db', volumes=[VolumeSpec.parse('/var/db')])
- project = Project('composetest', [web, db], self.client)
- project.create(['db', 'web'])
- project.create(['db', 'web'])
- containers = project.containers(stopped=True)
- assert len(containers) == 2
- db_containers = db.containers(stopped=True)
- assert len(db_containers) == 1
- assert not db_containers[0].is_running
- web_containers = web.containers(stopped=True)
- assert len(web_containers) == 1
- assert not web_containers[0].is_running
- def test_create_with_links(self):
- db = self.create_service('db')
- web = self.create_service('web', links=[(db, 'db')])
- project = Project('composetest', [db, web], self.client)
- project.create(['web'])
- # self.assertEqual(len(project.containers()), 0)
- assert len(project.containers(stopped=True)) == 2
- assert not [c for c in project.containers(stopped=True) if c.is_running]
- assert len(db.containers(stopped=True)) == 1
- assert len(web.containers(stopped=True)) == 1
- def test_create_strategy_always(self):
- db = self.create_service('db')
- project = Project('composetest', [db], self.client)
- project.create(['db'])
- old_id = project.containers(stopped=True)[0].id
- project.create(['db'], strategy=ConvergenceStrategy.always)
- assert len(project.containers(stopped=True)) == 1
- db_container = project.containers(stopped=True)[0]
- assert not db_container.is_running
- assert db_container.id != old_id
- def test_create_strategy_never(self):
- db = self.create_service('db')
- project = Project('composetest', [db], self.client)
- project.create(['db'])
- old_id = project.containers(stopped=True)[0].id
- project.create(['db'], strategy=ConvergenceStrategy.never)
- assert len(project.containers(stopped=True)) == 1
- db_container = project.containers(stopped=True)[0]
- assert not db_container.is_running
- assert db_container.id == old_id
- def test_project_up(self):
- web = self.create_service('web')
- db = self.create_service('db', volumes=[VolumeSpec.parse('/var/db')])
- project = Project('composetest', [web, db], self.client)
- project.start()
- assert len(project.containers()) == 0
- project.up(['db'])
- assert len(project.containers()) == 1
- assert len(db.containers()) == 1
- assert len(web.containers()) == 0
- def test_project_up_starts_uncreated_services(self):
- db = self.create_service('db')
- web = self.create_service('web', links=[(db, 'db')])
- project = Project('composetest', [db, web], self.client)
- project.up(['db'])
- assert len(project.containers()) == 1
- project.up()
- assert len(project.containers()) == 2
- assert len(db.containers()) == 1
- assert len(web.containers()) == 1
- def test_recreate_preserves_volumes(self):
- web = self.create_service('web')
- db = self.create_service('db', volumes=[VolumeSpec.parse('/etc')])
- project = Project('composetest', [web, db], self.client)
- project.start()
- assert len(project.containers()) == 0
- project.up(['db'])
- assert len(project.containers()) == 1
- old_db_id = project.containers()[0].id
- db_volume_path = project.containers()[0].get('Volumes./etc')
- project.up(strategy=ConvergenceStrategy.always)
- assert len(project.containers()) == 2
- db_container = [c for c in project.containers() if 'db' in c.name][0]
- assert db_container.id != old_db_id
- assert db_container.get('Volumes./etc') == db_volume_path
- @v2_3_only()
- def test_recreate_preserves_mounts(self):
- web = self.create_service('web')
- db = self.create_service('db', volumes=[types.MountSpec(type='volume', target='/etc')])
- project = Project('composetest', [web, db], self.client)
- project.start()
- assert len(project.containers()) == 0
- project.up(['db'])
- assert len(project.containers()) == 1
- old_db_id = project.containers()[0].id
- db_volume_path = project.containers()[0].get_mount('/etc')['Source']
- project.up(strategy=ConvergenceStrategy.always)
- assert len(project.containers()) == 2
- db_container = [c for c in project.containers() if 'db' in c.name][0]
- assert db_container.id != old_db_id
- assert db_container.get_mount('/etc')['Source'] == db_volume_path
- def test_project_up_with_no_recreate_running(self):
- web = self.create_service('web')
- db = self.create_service('db', volumes=[VolumeSpec.parse('/var/db')])
- project = Project('composetest', [web, db], self.client)
- project.start()
- assert len(project.containers()) == 0
- project.up(['db'])
- assert len(project.containers()) == 1
- container, = project.containers()
- old_db_id = container.id
- db_volume_path = container.get_mount('/var/db')['Source']
- project.up(strategy=ConvergenceStrategy.never)
- assert len(project.containers()) == 2
- db_container = [c for c in project.containers() if c.name == container.name][0]
- assert db_container.id == old_db_id
- assert db_container.get_mount('/var/db')['Source'] == db_volume_path
- def test_project_up_with_no_recreate_stopped(self):
- web = self.create_service('web')
- db = self.create_service('db', volumes=[VolumeSpec.parse('/var/db')])
- project = Project('composetest', [web, db], self.client)
- project.start()
- assert len(project.containers()) == 0
- project.up(['db'])
- project.kill()
- old_containers = project.containers(stopped=True)
- assert len(old_containers) == 1
- old_container, = old_containers
- old_db_id = old_container.id
- db_volume_path = old_container.get_mount('/var/db')['Source']
- project.up(strategy=ConvergenceStrategy.never)
- new_containers = project.containers(stopped=True)
- assert len(new_containers) == 2
- assert [c.is_running for c in new_containers] == [True, True]
- db_container = [c for c in new_containers if 'db' in c.name][0]
- assert db_container.id == old_db_id
- assert db_container.get_mount('/var/db')['Source'] == db_volume_path
- def test_project_up_without_all_services(self):
- console = self.create_service('console')
- db = self.create_service('db')
- project = Project('composetest', [console, db], self.client)
- project.start()
- assert len(project.containers()) == 0
- project.up()
- assert len(project.containers()) == 2
- assert len(db.containers()) == 1
- assert len(console.containers()) == 1
- def test_project_up_starts_links(self):
- console = self.create_service('console')
- db = self.create_service('db', volumes=[VolumeSpec.parse('/var/db')])
- web = self.create_service('web', links=[(db, 'db')])
- project = Project('composetest', [web, db, console], self.client)
- project.start()
- assert len(project.containers()) == 0
- project.up(['web'])
- assert len(project.containers()) == 2
- assert len(web.containers()) == 1
- assert len(db.containers()) == 1
- assert len(console.containers()) == 0
- def test_project_up_starts_depends(self):
- project = Project.from_config(
- name='composetest',
- config_data=load_config({
- 'console': {
- 'image': 'busybox:latest',
- 'command': ["top"],
- },
- 'data': {
- 'image': 'busybox:latest',
- 'command': ["top"]
- },
- 'db': {
- 'image': 'busybox:latest',
- 'command': ["top"],
- 'volumes_from': ['data'],
- },
- 'web': {
- 'image': 'busybox:latest',
- 'command': ["top"],
- 'links': ['db'],
- },
- }),
- client=self.client,
- )
- project.start()
- assert len(project.containers()) == 0
- project.up(['web'])
- assert len(project.containers()) == 3
- assert len(project.get_service('web').containers()) == 1
- assert len(project.get_service('db').containers()) == 1
- assert len(project.get_service('data').containers()) == 1
- assert len(project.get_service('console').containers()) == 0
- def test_project_up_with_no_deps(self):
- project = Project.from_config(
- name='composetest',
- config_data=load_config({
- 'console': {
- 'image': 'busybox:latest',
- 'command': ["top"],
- },
- 'data': {
- 'image': 'busybox:latest',
- 'command': ["top"]
- },
- 'db': {
- 'image': 'busybox:latest',
- 'command': ["top"],
- 'volumes_from': ['data'],
- },
- 'web': {
- 'image': 'busybox:latest',
- 'command': ["top"],
- 'links': ['db'],
- },
- }),
- client=self.client,
- )
- project.start()
- assert len(project.containers()) == 0
- project.up(['db'], start_deps=False)
- assert len(project.containers(stopped=True)) == 2
- assert len(project.get_service('web').containers()) == 0
- assert len(project.get_service('db').containers()) == 1
- assert len(project.get_service('data').containers(stopped=True)) == 1
- assert not project.get_service('data').containers(stopped=True)[0].is_running
- assert len(project.get_service('console').containers()) == 0
- def test_project_up_recreate_with_tmpfs_volume(self):
- # https://github.com/docker/compose/issues/4751
- project = Project.from_config(
- name='composetest',
- config_data=load_config({
- 'version': '2.1',
- 'services': {
- 'foo': {
- 'image': 'busybox:latest',
- 'tmpfs': ['/dev/shm'],
- 'volumes': ['/dev/shm']
- }
- }
- }), client=self.client
- )
- project.up()
- project.up(strategy=ConvergenceStrategy.always)
- def test_unscale_after_restart(self):
- web = self.create_service('web')
- project = Project('composetest', [web], self.client)
- project.start()
- service = project.get_service('web')
- service.scale(1)
- assert len(service.containers()) == 1
- service.scale(3)
- assert len(service.containers()) == 3
- project.up()
- service = project.get_service('web')
- assert len(service.containers()) == 1
- service.scale(1)
- assert len(service.containers()) == 1
- project.up(scale_override={'web': 3})
- service = project.get_service('web')
- assert len(service.containers()) == 3
- # does scale=0 ,makes any sense? after recreating at least 1 container is running
- service.scale(0)
- project.up()
- service = project.get_service('web')
- assert len(service.containers()) == 1
- @v2_only()
- def test_project_up_networks(self):
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top',
- 'networks': {
- 'foo': None,
- 'bar': None,
- 'baz': {'aliases': ['extra']},
- },
- }],
- networks={
- 'foo': {'driver': 'bridge'},
- 'bar': {'driver': None},
- 'baz': {},
- },
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up()
- containers = project.containers()
- assert len(containers) == 1
- container, = containers
- for net_name in ['foo', 'bar', 'baz']:
- full_net_name = 'composetest_{}'.format(net_name)
- network_data = self.client.inspect_network(full_net_name)
- assert network_data['Name'] == full_net_name
- aliases_key = 'NetworkSettings.Networks.{net}.Aliases'
- assert 'web' in container.get(aliases_key.format(net='composetest_foo'))
- assert 'web' in container.get(aliases_key.format(net='composetest_baz'))
- assert 'extra' in container.get(aliases_key.format(net='composetest_baz'))
- foo_data = self.client.inspect_network('composetest_foo')
- assert foo_data['Driver'] == 'bridge'
- @v2_only()
- def test_up_with_ipam_config(self):
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'networks': {'front': None},
- }],
- networks={
- 'front': {
- 'driver': 'bridge',
- 'driver_opts': {
- "com.docker.network.bridge.enable_icc": "false",
- },
- 'ipam': {
- 'driver': 'default',
- 'config': [{
- "subnet": "172.28.0.0/16",
- "ip_range": "172.28.5.0/24",
- "gateway": "172.28.5.254",
- "aux_addresses": {
- "a": "172.28.1.5",
- "b": "172.28.1.6",
- "c": "172.28.1.7",
- },
- }],
- },
- },
- },
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up()
- network = self.client.networks(names=['composetest_front'])[0]
- assert network['Options'] == {
- "com.docker.network.bridge.enable_icc": "false"
- }
- assert network['IPAM'] == {
- 'Driver': 'default',
- 'Options': None,
- 'Config': [{
- 'Subnet': "172.28.0.0/16",
- 'IPRange': "172.28.5.0/24",
- 'Gateway': "172.28.5.254",
- 'AuxiliaryAddresses': {
- 'a': '172.28.1.5',
- 'b': '172.28.1.6',
- 'c': '172.28.1.7',
- },
- }],
- }
- @v2_only()
- def test_up_with_ipam_options(self):
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'networks': {'front': None},
- }],
- networks={
- 'front': {
- 'driver': 'bridge',
- 'ipam': {
- 'driver': 'default',
- 'options': {
- "com.docker.compose.network.test": "9-29-045"
- }
- },
- },
- },
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up()
- network = self.client.networks(names=['composetest_front'])[0]
- assert network['IPAM']['Options'] == {
- "com.docker.compose.network.test": "9-29-045"
- }
- @v2_1_only()
- def test_up_with_network_static_addresses(self):
- config_data = build_config(
- version=V2_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top',
- 'networks': {
- 'static_test': {
- 'ipv4_address': '172.16.100.100',
- 'ipv6_address': 'fe80::1001:102'
- }
- },
- }],
- networks={
- 'static_test': {
- 'driver': 'bridge',
- 'driver_opts': {
- "com.docker.network.enable_ipv6": "true",
- },
- 'ipam': {
- 'driver': 'default',
- 'config': [
- {"subnet": "172.16.100.0/24",
- "gateway": "172.16.100.1"},
- {"subnet": "fe80::/64",
- "gateway": "fe80::1001:1"}
- ]
- },
- 'enable_ipv6': True,
- }
- }
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers()[0]
- ipam_config = (service_container.inspect().get('NetworkSettings', {}).
- get('Networks', {}).get('composetest_static_test', {}).
- get('IPAMConfig', {}))
- assert ipam_config.get('IPv4Address') == '172.16.100.100'
- assert ipam_config.get('IPv6Address') == 'fe80::1001:102'
- @v2_3_only()
- def test_up_with_network_priorities(self):
- mac_address = '74:6f:75:68:6f:75'
- def get_config_data(p1, p2, p3):
- return build_config(
- version=V2_3,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'networks': {
- 'n1': {
- 'priority': p1,
- },
- 'n2': {
- 'priority': p2,
- },
- 'n3': {
- 'priority': p3,
- }
- },
- 'command': 'top',
- 'mac_address': mac_address
- }],
- networks={
- 'n1': {},
- 'n2': {},
- 'n3': {}
- }
- )
- config1 = get_config_data(1000, 1, 1)
- config2 = get_config_data(2, 3, 1)
- config3 = get_config_data(5, 40, 100)
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config1
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers()[0]
- net_config = service_container.inspect()['NetworkSettings']['Networks']['composetest_n1']
- assert net_config['MacAddress'] == mac_address
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config2
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers()[0]
- net_config = service_container.inspect()['NetworkSettings']['Networks']['composetest_n2']
- assert net_config['MacAddress'] == mac_address
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config3
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers()[0]
- net_config = service_container.inspect()['NetworkSettings']['Networks']['composetest_n3']
- assert net_config['MacAddress'] == mac_address
- @v2_1_only()
- def test_up_with_enable_ipv6(self):
- self.require_api_version('1.23')
- config_data = build_config(
- version=V2_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top',
- 'networks': {
- 'static_test': {
- 'ipv6_address': 'fe80::1001:102'
- }
- },
- }],
- networks={
- 'static_test': {
- 'driver': 'bridge',
- 'enable_ipv6': True,
- 'ipam': {
- 'driver': 'default',
- 'config': [
- {"subnet": "fe80::/64",
- "gateway": "fe80::1001:1"}
- ]
- }
- }
- }
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up(detached=True)
- network = [n for n in self.client.networks() if 'static_test' in n['Name']][0]
- service_container = project.get_service('web').containers()[0]
- assert network['EnableIPv6'] is True
- ipam_config = (service_container.inspect().get('NetworkSettings', {}).
- get('Networks', {}).get('composetest_static_test', {}).
- get('IPAMConfig', {}))
- assert ipam_config.get('IPv6Address') == 'fe80::1001:102'
- @v2_only()
- def test_up_with_network_static_addresses_missing_subnet(self):
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'networks': {
- 'static_test': {
- 'ipv4_address': '172.16.100.100',
- 'ipv6_address': 'fe80::1001:101'
- }
- },
- }],
- networks={
- 'static_test': {
- 'driver': 'bridge',
- 'driver_opts': {
- "com.docker.network.enable_ipv6": "true",
- },
- 'ipam': {
- 'driver': 'default',
- },
- },
- },
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- with pytest.raises(ProjectError):
- project.up()
- @v2_1_only()
- def test_up_with_network_link_local_ips(self):
- config_data = build_config(
- version=V2_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'networks': {
- 'linklocaltest': {
- 'link_local_ips': ['169.254.8.8']
- }
- }
- }],
- networks={
- 'linklocaltest': {'driver': 'bridge'}
- }
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers(stopped=True)[0]
- ipam_config = service_container.inspect().get(
- 'NetworkSettings', {}
- ).get(
- 'Networks', {}
- ).get(
- 'composetest_linklocaltest', {}
- ).get('IPAMConfig', {})
- assert 'LinkLocalIPs' in ipam_config
- assert ipam_config['LinkLocalIPs'] == ['169.254.8.8']
- @v2_1_only()
- def test_up_with_custom_name_resources(self):
- config_data = build_config(
- version=V2_2,
- services=[{
- 'name': 'web',
- 'volumes': [VolumeSpec.parse('foo:/container-path')],
- 'networks': {'foo': {}},
- 'image': 'busybox:latest'
- }],
- networks={
- 'foo': {
- 'name': 'zztop',
- 'labels': {'com.docker.compose.test_value': 'sharpdressedman'}
- }
- },
- volumes={
- 'foo': {
- 'name': 'acdc',
- 'labels': {'com.docker.compose.test_value': 'thefuror'}
- }
- }
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- project.up(detached=True)
- network = [n for n in self.client.networks() if n['Name'] == 'zztop'][0]
- volume = [v for v in self.client.volumes()['Volumes'] if v['Name'] == 'acdc'][0]
- assert network['Labels']['com.docker.compose.test_value'] == 'sharpdressedman'
- assert volume['Labels']['com.docker.compose.test_value'] == 'thefuror'
- @v2_1_only()
- def test_up_with_isolation(self):
- self.require_api_version('1.24')
- config_data = build_config(
- version=V2_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'isolation': 'default'
- }],
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers(stopped=True)[0]
- assert service_container.inspect()['HostConfig']['Isolation'] == 'default'
- @v2_1_only()
- def test_up_with_invalid_isolation(self):
- self.require_api_version('1.24')
- config_data = build_config(
- version=V2_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'isolation': 'foobar'
- }],
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- with pytest.raises(ProjectError):
- project.up()
- @v2_3_only()
- @if_runtime_available('runc')
- def test_up_with_runtime(self):
- self.require_api_version('1.30')
- config_data = build_config(
- version=V2_3,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'runtime': 'runc'
- }],
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers(stopped=True)[0]
- assert service_container.inspect()['HostConfig']['Runtime'] == 'runc'
- @v2_3_only()
- def test_up_with_invalid_runtime(self):
- self.require_api_version('1.30')
- config_data = build_config(
- version=V2_3,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'runtime': 'foobar'
- }],
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- with pytest.raises(ProjectError):
- project.up()
- @v2_3_only()
- @if_runtime_available('nvidia')
- def test_up_with_nvidia_runtime(self):
- self.require_api_version('1.30')
- config_data = build_config(
- version=V2_3,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'runtime': 'nvidia'
- }],
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- project.up(detached=True)
- service_container = project.get_service('web').containers(stopped=True)[0]
- assert service_container.inspect()['HostConfig']['Runtime'] == 'nvidia'
- @v2_only()
- def test_project_up_with_network_internal(self):
- self.require_api_version('1.23')
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'networks': {'internal': None},
- }],
- networks={
- 'internal': {'driver': 'bridge', 'internal': True},
- },
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up()
- network = self.client.networks(names=['composetest_internal'])[0]
- assert network['Internal'] is True
- @v2_1_only()
- def test_project_up_with_network_label(self):
- self.require_api_version('1.23')
- network_name = 'network_with_label'
- config_data = build_config(
- version=V2_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'networks': {network_name: None}
- }],
- networks={
- network_name: {'labels': {'label_key': 'label_val'}}
- }
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data
- )
- project.up()
- networks = [
- n for n in self.client.networks()
- if n['Name'].startswith('composetest_')
- ]
- assert [n['Name'] for n in networks] == ['composetest_{}'.format(network_name)]
- assert 'label_key' in networks[0]['Labels']
- assert networks[0]['Labels']['label_key'] == 'label_val'
- @v2_only()
- def test_project_up_volumes(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={vol_name: {'driver': 'local'}},
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- project.up()
- assert len(project.containers()) == 1
- volume_data = self.get_volume_data(full_vol_name)
- assert volume_data['Name'].split('/')[-1] == full_vol_name
- assert volume_data['Driver'] == 'local'
- @v2_1_only()
- def test_project_up_with_volume_labels(self):
- self.require_api_version('1.23')
- volume_name = 'volume_with_label'
- config_data = build_config(
- version=V2_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'volumes': [VolumeSpec.parse('{}:/data'.format(volume_name))]
- }],
- volumes={
- volume_name: {
- 'labels': {
- 'label_key': 'label_val'
- }
- }
- },
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up()
- volumes = [
- v for v in self.client.volumes().get('Volumes', [])
- if v['Name'].split('/')[-1].startswith('composetest_')
- ]
- assert set([v['Name'].split('/')[-1] for v in volumes]) == set(
- ['composetest_{}'.format(volume_name)]
- )
- assert 'label_key' in volumes[0]['Labels']
- assert volumes[0]['Labels']['label_key'] == 'label_val'
- @v2_only()
- def test_project_up_logging_with_multiple_files(self):
- base_file = config.ConfigFile(
- 'base.yml',
- {
- 'version': str(V2_0),
- 'services': {
- 'simple': {'image': 'busybox:latest', 'command': 'top'},
- 'another': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'logging': {
- 'driver': "json-file",
- 'options': {
- 'max-size': "10m"
- }
- }
- }
- }
- })
- override_file = config.ConfigFile(
- 'override.yml',
- {
- 'version': str(V2_0),
- 'services': {
- 'another': {
- 'logging': {
- 'driver': "none"
- }
- }
- }
- })
- details = config.ConfigDetails('.', [base_file, override_file])
- tmpdir = py.test.ensuretemp('logging_test')
- self.addCleanup(tmpdir.remove)
- with tmpdir.as_cwd():
- config_data = config.load(details)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- project.up()
- containers = project.containers()
- assert len(containers) == 2
- another = project.get_service('another').containers()[0]
- log_config = another.get('HostConfig.LogConfig')
- assert log_config
- assert log_config.get('Type') == 'none'
- @v2_only()
- def test_project_up_port_mappings_with_multiple_files(self):
- base_file = config.ConfigFile(
- 'base.yml',
- {
- 'version': str(V2_0),
- 'services': {
- 'simple': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'ports': ['1234:1234']
- },
- },
- })
- override_file = config.ConfigFile(
- 'override.yml',
- {
- 'version': str(V2_0),
- 'services': {
- 'simple': {
- 'ports': ['1234:1234']
- }
- }
- })
- details = config.ConfigDetails('.', [base_file, override_file])
- config_data = config.load(details)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- project.up()
- containers = project.containers()
- assert len(containers) == 1
- @v2_2_only()
- def test_project_up_config_scale(self):
- config_data = build_config(
- version=V2_2,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top',
- 'scale': 3
- }]
- )
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- project.up()
- assert len(project.containers()) == 3
- project.up(scale_override={'web': 2})
- assert len(project.containers()) == 2
- project.up(scale_override={'web': 4})
- assert len(project.containers()) == 4
- project.stop()
- project.up()
- assert len(project.containers()) == 3
- @v2_only()
- def test_initialize_volumes(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={vol_name: {}},
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- project.volumes.initialize()
- volume_data = self.get_volume_data(full_vol_name)
- assert volume_data['Name'].split('/')[-1] == full_vol_name
- assert volume_data['Driver'] == 'local'
- @v2_only()
- def test_project_up_implicit_volume_driver(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={vol_name: {}},
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- project.up()
- volume_data = self.get_volume_data(full_vol_name)
- assert volume_data['Name'].split('/')[-1] == full_vol_name
- assert volume_data['Driver'] == 'local'
- @v3_only()
- def test_project_up_with_secrets(self):
- node = create_host_file(self.client, os.path.abspath('tests/fixtures/secrets/default'))
- config_data = build_config(
- version=V3_1,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'cat /run/secrets/special',
- 'secrets': [
- types.ServiceSecret.parse({'source': 'super', 'target': 'special'}),
- ],
- 'environment': ['constraint:node=={}'.format(node if node is not None else '*')]
- }],
- secrets={
- 'super': {
- 'file': os.path.abspath('tests/fixtures/secrets/default'),
- },
- },
- )
- project = Project.from_config(
- client=self.client,
- name='composetest',
- config_data=config_data,
- )
- project.up()
- project.stop()
- containers = project.containers(stopped=True)
- assert len(containers) == 1
- container, = containers
- output = container.logs()
- assert output == b"This is the secret\n"
- @v2_only()
- def test_initialize_volumes_invalid_volume_driver(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={vol_name: {'driver': 'foobar'}},
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- with pytest.raises(APIError if is_cluster(self.client) else config.ConfigurationError):
- project.volumes.initialize()
- @v2_only()
- @no_cluster('inspect volume by name defect on Swarm Classic')
- def test_initialize_volumes_updated_driver(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={vol_name: {'driver': 'local'}},
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- project.volumes.initialize()
- volume_data = self.get_volume_data(full_vol_name)
- assert volume_data['Name'].split('/')[-1] == full_vol_name
- assert volume_data['Driver'] == 'local'
- config_data = config_data._replace(
- volumes={vol_name: {'driver': 'smb'}}
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data,
- client=self.client
- )
- with pytest.raises(config.ConfigurationError) as e:
- project.volumes.initialize()
- assert 'Configuration for volume {0} specifies driver smb'.format(
- vol_name
- ) in str(e.value)
- @v2_only()
- @no_cluster('inspect volume by name defect on Swarm Classic')
- def test_initialize_volumes_updated_driver_opts(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- tmpdir = tempfile.mkdtemp(prefix='compose_test_')
- self.addCleanup(shutil.rmtree, tmpdir)
- driver_opts = {'o': 'bind', 'device': tmpdir, 'type': 'none'}
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={
- vol_name: {
- 'driver': 'local',
- 'driver_opts': driver_opts
- }
- },
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- project.volumes.initialize()
- volume_data = self.get_volume_data(full_vol_name)
- assert volume_data['Name'].split('/')[-1] == full_vol_name
- assert volume_data['Driver'] == 'local'
- assert volume_data['Options'] == driver_opts
- driver_opts['device'] = '/opt/data/localdata'
- project = Project.from_config(
- name='composetest',
- config_data=config_data,
- client=self.client
- )
- with pytest.raises(config.ConfigurationError) as e:
- project.volumes.initialize()
- assert 'Configuration for volume {0} specifies "device" driver_opt {1}'.format(
- vol_name, driver_opts['device']
- ) in str(e.value)
- @v2_only()
- def test_initialize_volumes_updated_blank_driver(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={vol_name: {'driver': 'local'}},
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- project.volumes.initialize()
- volume_data = self.get_volume_data(full_vol_name)
- assert volume_data['Name'].split('/')[-1] == full_vol_name
- assert volume_data['Driver'] == 'local'
- config_data = config_data._replace(
- volumes={vol_name: {}}
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data,
- client=self.client
- )
- project.volumes.initialize()
- volume_data = self.get_volume_data(full_vol_name)
- assert volume_data['Name'].split('/')[-1] == full_vol_name
- assert volume_data['Driver'] == 'local'
- @v2_only()
- @no_cluster('inspect volume by name defect on Swarm Classic')
- def test_initialize_volumes_external_volumes(self):
- # Use composetest_ prefix so it gets garbage-collected in tearDown()
- vol_name = 'composetest_{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- self.client.create_volume(vol_name)
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={
- vol_name: {'external': True, 'name': vol_name}
- },
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- project.volumes.initialize()
- with pytest.raises(NotFound):
- self.client.inspect_volume(full_vol_name)
- @v2_only()
- def test_initialize_volumes_inexistent_external_volume(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- config_data = build_config(
- version=V2_0,
- services=[{
- 'name': 'web',
- 'image': 'busybox:latest',
- 'command': 'top'
- }],
- volumes={
- vol_name: {'external': True, 'name': vol_name}
- },
- )
- project = Project.from_config(
- name='composetest',
- config_data=config_data, client=self.client
- )
- with pytest.raises(config.ConfigurationError) as e:
- project.volumes.initialize()
- assert 'Volume {0} declared as external'.format(
- vol_name
- ) in str(e.value)
- @v2_only()
- def test_project_up_named_volumes_in_binds(self):
- vol_name = '{0:x}'.format(random.getrandbits(32))
- full_vol_name = 'composetest_{0}'.format(vol_name)
- base_file = config.ConfigFile(
- 'base.yml',
- {
- 'version': str(V2_0),
- 'services': {
- 'simple': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'volumes': ['{0}:/data'.format(vol_name)]
- },
- },
- 'volumes': {
- vol_name: {'driver': 'local'}
- }
- })
- config_details = config.ConfigDetails('.', [base_file])
- config_data = config.load(config_details)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- service = project.services[0]
- assert service.name == 'simple'
- volumes = service.options.get('volumes')
- assert len(volumes) == 1
- assert volumes[0].external == full_vol_name
- project.up()
- engine_volumes = self.client.volumes()['Volumes']
- container = service.get_container()
- assert [mount['Name'] for mount in container.get('Mounts')] == [full_vol_name]
- assert next((v for v in engine_volumes if v['Name'] == vol_name), None) is None
- def test_project_up_orphans(self):
- config_dict = {
- 'service1': {
- 'image': 'busybox:latest',
- 'command': 'top',
- }
- }
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- project.up()
- config_dict['service2'] = config_dict['service1']
- del config_dict['service1']
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- with mock.patch('compose.project.log') as mock_log:
- project.up()
- mock_log.warning.assert_called_once_with(mock.ANY)
- assert len([
- ctnr for ctnr in project._labeled_containers()
- if ctnr.labels.get(LABEL_SERVICE) == 'service1'
- ]) == 1
- project.up(remove_orphans=True)
- assert len([
- ctnr for ctnr in project._labeled_containers()
- if ctnr.labels.get(LABEL_SERVICE) == 'service1'
- ]) == 0
- def test_project_up_ignore_orphans(self):
- config_dict = {
- 'service1': {
- 'image': 'busybox:latest',
- 'command': 'top',
- }
- }
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- project.up()
- config_dict['service2'] = config_dict['service1']
- del config_dict['service1']
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- with mock.patch('compose.project.log') as mock_log:
- project.up(ignore_orphans=True)
- mock_log.warning.assert_not_called()
- @v2_1_only()
- def test_project_up_healthy_dependency(self):
- config_dict = {
- 'version': '2.1',
- 'services': {
- 'svc1': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'healthcheck': {
- 'test': 'exit 0',
- 'retries': 1,
- 'timeout': '10s',
- 'interval': '1s'
- },
- },
- 'svc2': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'depends_on': {
- 'svc1': {'condition': 'service_healthy'},
- }
- }
- }
- }
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- project.up()
- containers = project.containers()
- assert len(containers) == 2
- svc1 = project.get_service('svc1')
- svc2 = project.get_service('svc2')
- assert 'svc1' in svc2.get_dependency_names()
- assert svc1.is_healthy()
- @v2_1_only()
- def test_project_up_unhealthy_dependency(self):
- config_dict = {
- 'version': '2.1',
- 'services': {
- 'svc1': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'healthcheck': {
- 'test': 'exit 1',
- 'retries': 1,
- 'timeout': '10s',
- 'interval': '1s'
- },
- },
- 'svc2': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'depends_on': {
- 'svc1': {'condition': 'service_healthy'},
- }
- }
- }
- }
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- with pytest.raises(ProjectError):
- project.up()
- containers = project.containers()
- assert len(containers) == 1
- svc1 = project.get_service('svc1')
- svc2 = project.get_service('svc2')
- assert 'svc1' in svc2.get_dependency_names()
- with pytest.raises(HealthCheckFailed):
- svc1.is_healthy()
- @v2_1_only()
- def test_project_up_no_healthcheck_dependency(self):
- config_dict = {
- 'version': '2.1',
- 'services': {
- 'svc1': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'healthcheck': {
- 'disable': True
- },
- },
- 'svc2': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'depends_on': {
- 'svc1': {'condition': 'service_healthy'},
- }
- }
- }
- }
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='composetest', config_data=config_data, client=self.client
- )
- with pytest.raises(ProjectError):
- project.up()
- containers = project.containers()
- assert len(containers) == 1
- svc1 = project.get_service('svc1')
- svc2 = project.get_service('svc2')
- assert 'svc1' in svc2.get_dependency_names()
- with pytest.raises(NoHealthCheckConfigured):
- svc1.is_healthy()
- def test_project_up_seccomp_profile(self):
- seccomp_data = {
- 'defaultAction': 'SCMP_ACT_ALLOW',
- 'syscalls': []
- }
- fd, profile_path = tempfile.mkstemp('_seccomp.json')
- self.addCleanup(os.remove, profile_path)
- with os.fdopen(fd, 'w') as f:
- json.dump(seccomp_data, f)
- config_dict = {
- 'version': '2.3',
- 'services': {
- 'svc1': {
- 'image': 'busybox:latest',
- 'command': 'top',
- 'security_opt': ['seccomp:"{}"'.format(profile_path)]
- }
- }
- }
- config_data = load_config(config_dict)
- project = Project.from_config(name='composetest', config_data=config_data, client=self.client)
- project.up()
- containers = project.containers()
- assert len(containers) == 1
- remote_secopts = containers[0].get('HostConfig.SecurityOpt')
- assert len(remote_secopts) == 1
- assert remote_secopts[0].startswith('seccomp=')
- assert json.loads(remote_secopts[0].lstrip('seccomp=')) == seccomp_data
- @no_cluster('inspect volume by name defect on Swarm Classic')
- def test_project_up_name_starts_with_illegal_char(self):
- config_dict = {
- 'version': '2.3',
- 'services': {
- 'svc1': {
- 'image': 'busybox:latest',
- 'command': 'ls',
- 'volumes': ['foo:/foo:rw'],
- 'networks': ['bar'],
- },
- },
- 'volumes': {
- 'foo': {},
- },
- 'networks': {
- 'bar': {},
- }
- }
- config_data = load_config(config_dict)
- project = Project.from_config(
- name='_underscoretest', config_data=config_data, client=self.client
- )
- project.up()
- self.addCleanup(project.down, None, True)
- containers = project.containers(stopped=True)
- assert len(containers) == 1
- assert containers[0].name.startswith('underscoretest_svc1_')
- assert containers[0].project == '_underscoretest'
- full_vol_name = 'underscoretest_foo'
- vol_data = self.get_volume_data(full_vol_name)
- assert vol_data
- assert vol_data['Labels'][LABEL_PROJECT] == '_underscoretest'
- full_net_name = '_underscoretest_bar'
- net_data = self.client.inspect_network(full_net_name)
- assert net_data
- assert net_data['Labels'][LABEL_PROJECT] == '_underscoretest'
- project2 = Project.from_config(
- name='-dashtest', config_data=config_data, client=self.client
- )
- project2.up()
- self.addCleanup(project2.down, None, True)
- containers = project2.containers(stopped=True)
- assert len(containers) == 1
- assert containers[0].name.startswith('dashtest_svc1_')
- assert containers[0].project == '-dashtest'
- full_vol_name = 'dashtest_foo'
- vol_data = self.get_volume_data(full_vol_name)
- assert vol_data
- assert vol_data['Labels'][LABEL_PROJECT] == '-dashtest'
- full_net_name = '-dashtest_bar'
- net_data = self.client.inspect_network(full_net_name)
- assert net_data
- assert net_data['Labels'][LABEL_PROJECT] == '-dashtest'
|