1
1
# -*- coding: utf-8 -*-
2
+
2
3
"""
3
4
Tasks related to projects.
4
5
26
27
from builtins import str
27
28
from celery .exceptions import SoftTimeLimitExceeded
28
29
from django .conf import settings
29
- from django .urls import reverse
30
30
from django .db .models import Q
31
+ from django .urls import reverse
31
32
from django .utils import timezone
32
33
from django .utils .translation import ugettext_lazy as _
33
34
from slumber .exceptions import HttpClientError
56
57
)
57
58
from readthedocs .doc_builder .exceptions import (
58
59
BuildEnvironmentError ,
60
+ BuildEnvironmentWarning ,
59
61
BuildTimeoutError ,
62
+ MkDocsYAMLParseError ,
60
63
ProjectBuildsSkippedError ,
61
64
VersionLockedError ,
62
65
YAMLParseError ,
63
- BuildEnvironmentWarning ,
64
- MkDocsYAMLParseError ,
65
66
)
66
67
from readthedocs .doc_builder .loader import get_builder_class
67
68
from readthedocs .doc_builder .python_environments import Conda , Virtualenv
73
74
from readthedocs .worker import app
74
75
75
76
from .constants import LOG_TEMPLATE
76
- from .exceptions import RepositoryError , ProjectConfigurationError
77
+ from .exceptions import ProjectConfigurationError , RepositoryError
77
78
from .models import Domain , ImportedFile , Project
78
79
from .signals import (
79
80
after_build ,
80
81
after_vcs ,
81
82
before_build ,
82
83
before_vcs ,
83
- files_changed ,
84
84
domain_verify ,
85
+ files_changed ,
85
86
)
86
87
88
+
87
89
log = logging .getLogger (__name__ )
88
90
89
91
@@ -212,7 +214,7 @@ def validate_duplicate_reserved_versions(self, data):
212
214
for reserved_name in [STABLE_VERBOSE_NAME , LATEST_VERBOSE_NAME ]:
213
215
if counter [reserved_name ] > 1 :
214
216
raise RepositoryError (
215
- RepositoryError .DUPLICATED_RESERVED_VERSIONS
217
+ RepositoryError .DUPLICATED_RESERVED_VERSIONS ,
216
218
)
217
219
218
220
@@ -270,7 +272,6 @@ def run(self, version_pk): # pylint: disable=arguments-differ
270
272
'version' : self .version .slug ,
271
273
},
272
274
},
273
-
274
275
)
275
276
return False
276
277
@@ -398,7 +399,7 @@ def run(self, pk, version_pk=None, build_pk=None, record=True,
398
399
self .setup_env .failure = BuildEnvironmentError (
399
400
BuildEnvironmentError .GENERIC_WITH_BUILD_ID .format (
400
401
build_id = build_pk ,
401
- )
402
+ ),
402
403
)
403
404
self .setup_env .update_build (BUILD_STATE_FINISHED )
404
405
@@ -426,7 +427,7 @@ def run(self, pk, version_pk=None, build_pk=None, record=True,
426
427
self .build_env .failure = BuildEnvironmentError (
427
428
BuildEnvironmentError .GENERIC_WITH_BUILD_ID .format (
428
429
build_id = build_pk ,
429
- )
430
+ ),
430
431
)
431
432
self .build_env .update_build (BUILD_STATE_FINISHED )
432
433
@@ -465,7 +466,7 @@ def run_setup(self, record=True):
465
466
raise YAMLParseError (
466
467
YAMLParseError .GENERIC_WITH_PARSE_EXCEPTION .format (
467
468
exception = str (e ),
468
- )
469
+ ),
469
470
)
470
471
471
472
self .save_build_config ()
@@ -811,7 +812,7 @@ def build_docs_html(self):
811
812
type = 'app' ,
812
813
task = move_files ,
813
814
args = [self .version .pk , socket .gethostname ()],
814
- kwargs = dict (html = True )
815
+ kwargs = dict (html = True ),
815
816
)
816
817
except socket .error :
817
818
log .exception ('move_files task has failed on socket error.' )
@@ -863,7 +864,7 @@ def build_docs_class(self, builder_class):
863
864
"""
864
865
builder = get_builder_class (builder_class )(
865
866
self .build_env ,
866
- python_env = self .python_env
867
+ python_env = self .python_env ,
867
868
)
868
869
success = builder .build ()
869
870
builder .move ()
@@ -948,7 +949,7 @@ def move_files(version_pk, hostname, html=False, localmedia=False,
948
949
project = version .project .slug ,
949
950
version = version .slug ,
950
951
msg = 'Moving files' ,
951
- )
952
+ ),
952
953
)
953
954
954
955
if html :
@@ -1025,7 +1026,7 @@ def update_search(version_pk, commit, delete_non_commit_files=True):
1025
1026
else :
1026
1027
log .debug (
1027
1028
'Unknown documentation type: %s' ,
1028
- version .project .documentation_type
1029
+ version .project .documentation_type ,
1029
1030
)
1030
1031
return
1031
1032
@@ -1120,7 +1121,7 @@ def fileify(version_pk, commit):
1120
1121
'Imported File not being built because no commit '
1121
1122
'information'
1122
1123
),
1123
- )
1124
+ ),
1124
1125
)
1125
1126
return
1126
1127
@@ -1131,7 +1132,7 @@ def fileify(version_pk, commit):
1131
1132
project = version .project .slug ,
1132
1133
version = version .slug ,
1133
1134
msg = 'Creating ImportedFiles' ,
1134
- )
1135
+ ),
1135
1136
)
1136
1137
_manage_imported_files (version , path , commit )
1137
1138
else :
@@ -1140,7 +1141,7 @@ def fileify(version_pk, commit):
1140
1141
project = project .slug ,
1141
1142
version = version .slug ,
1142
1143
msg = 'No ImportedFile files' ,
1143
- )
1144
+ ),
1144
1145
)
1145
1146
1146
1147
@@ -1212,7 +1213,7 @@ def email_notification(version, build, email):
1212
1213
project = version .project .slug ,
1213
1214
version = version .slug ,
1214
1215
msg = 'sending email to: %s' % email ,
1215
- )
1216
+ ),
1216
1217
)
1217
1218
1218
1219
# We send only what we need from the Django model objects here to avoid
@@ -1276,7 +1277,7 @@ def webhook_notification(version, build, hook_url):
1276
1277
project = project .slug ,
1277
1278
version = '' ,
1278
1279
msg = 'sending notification to: %s' % hook_url ,
1279
- )
1280
+ ),
1280
1281
)
1281
1282
try :
1282
1283
requests .post (hook_url , data = data )
@@ -1309,7 +1310,7 @@ def update_static_metadata(project_pk, path=None):
1309
1310
project = project .slug ,
1310
1311
version = '' ,
1311
1312
msg = 'Updating static metadata' ,
1312
- )
1313
+ ),
1313
1314
)
1314
1315
translations = [trans .language for trans in project .translations .all ()]
1315
1316
languages = set (translations )
@@ -1332,7 +1333,7 @@ def update_static_metadata(project_pk, path=None):
1332
1333
project = project .slug ,
1333
1334
version = '' ,
1334
1335
msg = 'Cannot write to metadata.json: {0}' .format (e ),
1335
- )
1336
+ ),
1336
1337
)
1337
1338
1338
1339
@@ -1412,7 +1413,7 @@ def finish_inactive_builds():
1412
1413
@app .task (queue = 'web' )
1413
1414
def retry_domain_verification (domain_pk ):
1414
1415
"""
1415
- Trigger domain verification on a domain
1416
+ Trigger domain verification on a domain.
1416
1417
1417
1418
:param domain_pk: a `Domain` pk to verify
1418
1419
"""
0 commit comments