@@ -140,30 +140,37 @@ def submit_task_to_db(task, task_submitter, db_path):
140
140
status = "failed"
141
141
task_id = "-1"
142
142
result = {"status" : status , "task_id" : task_id , "msg" : msg }
143
+ if not is_valid_task (task .__dict__ ):
144
+ return result
143
145
if os .path .isfile (db_path ):
144
146
conn = sqlite3 .connect (db_path )
145
147
cursor = conn .cursor ()
146
148
task_id = str (uuid .uuid4 ()).replace ("-" , "" )
147
149
sql = (
148
- r"insert into task(id, script_url, optimized, arguments, approach, requirements, workers, status)"
149
- + r" values ('{}', '{}', {}, '{}', '{}', '{}', {}, 'pending')" .format (
150
- task_id ,
151
- task .script_url ,
152
- task .optimized ,
153
- list_to_string (task .arguments ),
154
- task .approach ,
155
- list_to_string (task .requirements ),
156
- task .workers ,
157
- )
150
+ "INSERT INTO task "
151
+ "(id, script_url, optimized, arguments, approach, requirements, workers, status) "
152
+ "VALUES (?, ?, ?, ?, ?, ?, ?, 'pending')"
158
153
)
159
- cursor .execute (sql )
154
+
155
+ task_params = (
156
+ task_id ,
157
+ task .script_url ,
158
+ task .optimized ,
159
+ list_to_string (task .arguments ),
160
+ task .approach ,
161
+ list_to_string (task .requirements ),
162
+ task .workers ,
163
+ )
164
+
165
+ conn .execute (sql , task_params )
160
166
conn .commit ()
161
167
try :
162
168
task_submitter .submit_task (task_id )
163
169
except ConnectionRefusedError :
164
170
msg = "Task Submitted fail! Make sure neural solution runner is running!"
165
171
except Exception as e :
166
- msg = "Task Submitted fail! {}" .format (e )
172
+ msg = "Task Submitted fail!"
173
+ print (f"{ msg } { e } " )
167
174
conn .close ()
168
175
status = "successfully"
169
176
msg = "Task submitted successfully"
0 commit comments