19
19
log_level = int (os .environ .get ("LAMBDA_BUILDERS_LOG_LEVEL" , logging .INFO ))
20
20
21
21
# Write output to stderr because stdout is used for command response
22
- logging .basicConfig (stream = sys .stderr ,
23
- level = log_level ,
24
- format = '%(message)s' )
22
+ logging .basicConfig (stream = sys .stderr , level = log_level , format = "%(message)s" )
25
23
26
24
LOG = logging .getLogger (__name__ )
27
25
28
26
VERSION_REGEX = re .compile ("^([0-9])+.([0-9]+)$" )
29
27
30
28
31
29
def _success_response (request_id , artifacts_dir ):
32
- return json .dumps ({
33
- "jsonrpc" : "2.0" ,
34
- "id" : request_id ,
35
- "result" : {
36
- "artifacts_dir" : artifacts_dir
37
- }
38
- })
30
+ return json .dumps ({"jsonrpc" : "2.0" , "id" : request_id , "result" : {"artifacts_dir" : artifacts_dir }})
39
31
40
32
41
33
def _error_response (request_id , http_status_code , message ):
42
- return json .dumps ({
43
- "jsonrpc" : "2.0" ,
44
- "id" : request_id ,
45
- "error" : {
46
- "code" : http_status_code ,
47
- "message" : message
48
- }
49
- })
34
+ return json .dumps ({"jsonrpc" : "2.0" , "id" : request_id , "error" : {"code" : http_status_code , "message" : message }})
50
35
51
36
52
37
def _parse_version (version_string ):
@@ -68,8 +53,9 @@ def version_compatibility_check(version):
68
53
# 0.2 < 0.1 comparison will fail, don't throw a value Error saying incompatible version
69
54
70
55
if _parse_version (lambda_builders_protocol_version ) < version :
71
- ex = "Incompatible Protocol Version : {}, " \
72
- "Current Protocol Version: {}" .format (version , lambda_builders_protocol_version )
56
+ ex = "Incompatible Protocol Version : {}, " "Current Protocol Version: {}" .format (
57
+ version , lambda_builders_protocol_version
58
+ )
73
59
LOG .error (ex )
74
60
raise ValueError (ex )
75
61
@@ -120,21 +106,25 @@ def main(): # pylint: disable=too-many-statements
120
106
response = None
121
107
122
108
try :
123
- builder = LambdaBuilder (language = capabilities ["language" ],
124
- dependency_manager = capabilities ["dependency_manager" ],
125
- application_framework = capabilities ["application_framework" ],
126
- supported_workflows = supported_workflows )
109
+ builder = LambdaBuilder (
110
+ language = capabilities ["language" ],
111
+ dependency_manager = capabilities ["dependency_manager" ],
112
+ application_framework = capabilities ["application_framework" ],
113
+ supported_workflows = supported_workflows ,
114
+ )
127
115
128
116
artifacts_dir = params ["artifacts_dir" ]
129
- builder .build (params ["source_dir" ],
130
- params ["artifacts_dir" ],
131
- params ["scratch_dir" ],
132
- params ["manifest_path" ],
133
- executable_search_paths = params .get ('executable_search_paths' , None ),
134
- runtime = params ["runtime" ],
135
- optimizations = params ["optimizations" ],
136
- options = params ["options" ],
137
- mode = params .get ('mode' , None ))
117
+ builder .build (
118
+ params ["source_dir" ],
119
+ params ["artifacts_dir" ],
120
+ params ["scratch_dir" ],
121
+ params ["manifest_path" ],
122
+ executable_search_paths = params .get ("executable_search_paths" , None ),
123
+ runtime = params ["runtime" ],
124
+ optimizations = params ["optimizations" ],
125
+ options = params ["options" ],
126
+ mode = params .get ("mode" , None ),
127
+ )
138
128
139
129
# Return a success response
140
130
response = _success_response (request_id , artifacts_dir )
@@ -152,5 +142,5 @@ def main(): # pylint: disable=too-many-statements
152
142
_write_response (response , exit_code )
153
143
154
144
155
- if __name__ == ' __main__' :
145
+ if __name__ == " __main__" :
156
146
main ()
0 commit comments