@@ -912,15 +912,17 @@ def pull(self, repository, tag=None, stream=False,
912
912
else :
913
913
headers ['X-Registry-Auth' ] = auth .encode_header (auth_config )
914
914
915
- response = self ._post (self ._url ('/images/create' ), params = params ,
916
- headers = headers , stream = stream , timeout = None )
915
+ response = self ._post (
916
+ self ._url ('/images/create' ), params = params , headers = headers ,
917
+ stream = stream , timeout = None
918
+ )
917
919
918
920
self ._raise_for_status (response )
919
921
920
922
if stream :
921
923
return self ._stream_helper (response )
922
- else :
923
- return self ._result (response )
924
+
925
+ return self ._result (response )
924
926
925
927
def push (self , repository , tag = None , stream = False ,
926
928
insecure_registry = False ):
@@ -948,15 +950,16 @@ def push(self, repository, tag=None, stream=False,
948
950
if authcfg :
949
951
headers ['X-Registry-Auth' ] = auth .encode_header (authcfg )
950
952
951
- response = self ._post_json (u , None , headers = headers ,
952
- stream = stream , params = params )
953
- else :
954
- response = self ._post_json (u , None , stream = stream , params = params )
953
+ response = self ._post_json (
954
+ u , None , headers = headers , stream = stream , params = params
955
+ )
955
956
956
957
self ._raise_for_status (response )
957
958
958
- return stream and self ._stream_helper (response ) \
959
- or self ._result (response )
959
+ if stream :
960
+ return self ._stream_helper (response )
961
+
962
+ return self ._result (response )
960
963
961
964
@check_resource
962
965
def remove_container (self , container , v = False , link = False , force = False ):
0 commit comments