Codestyle enhancements

This commit is contained in:
Patrick Jentsch 2021-12-08 14:45:05 +01:00
parent 1fd7a2e38c
commit 3d99b8770c
10 changed files with 44 additions and 41 deletions

View File

@ -69,8 +69,7 @@ def register():
os.makedirs(user.path) os.makedirs(user.path)
except OSError: except OSError:
current_app.logger.error( current_app.logger.error(
'Make dir {} led to an OSError!'.format(user.path) f'Make dir {user.path} led to an OSError!')
)
db.session.delete(user) db.session.delete(user)
db.session.commit() db.session.commit()
abort(500) abort(500)

View File

@ -82,7 +82,7 @@ def connect(auth):
socketio.sleep(3) socketio.sleep(3)
retry_counter -= 1 retry_counter -= 1
db.session.refresh(corpus) db.session.refresh(corpus)
cqi_client = cqi.CQiClient('cqpserver_{}'.format(corpus_id)) cqi_client = cqi.CQiClient(f'cqpserver_{corpus_id}')
session['d'] = { session['d'] = {
'corpus_id': corpus_id, 'corpus_id': corpus_id,
'cqi_client': cqi_client, 'cqi_client': cqi_client,

View File

@ -33,8 +33,7 @@ def add_query_result():
os.makedirs(os.path.dirname(query_result.path)) os.makedirs(os.path.dirname(query_result.path))
except OSError: except OSError:
current_app.logger.error( current_app.logger.error(
'Make dir {} led to an OSError!'.format(query_result.path) f'Make dir {query_result.path} led to an OSError!')
)
db.session.rollback() db.session.rollback()
flash('Internal Server Error', 'error') flash('Internal Server Error', 'error')
return make_response( return make_response(
@ -99,13 +98,15 @@ def inspect_query_result(query_result_id):
) )
with open(query_result.path, 'r') as query_result_file: with open(query_result.path, 'r') as query_result_file:
query_result_file_content = json.load(query_result_file) query_result_file_content = json.load(query_result_file)
return render_template('corpora/query_results/inspect.html.j2', return render_template(
query_result=query_result, 'corpora/query_results/inspect.html.j2',
display_options_form=display_options_form, query_result=query_result,
inspect_display_options_form=inspect_display_options_form, # noqa display_options_form=display_options_form,
query_result_file_content=query_result_file_content, inspect_display_options_form=inspect_display_options_form, # noqa
query_metadata=query_metadata, query_result_file_content=query_result_file_content,
title='Inspect query result') query_metadata=query_metadata,
title='Inspect query result'
)
@bp.route('/result/<hashid:query_result_id>/delete') @bp.route('/result/<hashid:query_result_id>/delete')
@ -116,7 +117,7 @@ def delete_query_result(query_result_id):
if not (query_result.user == current_user if not (query_result.user == current_user
or current_user.is_administrator()): or current_user.is_administrator()):
abort(403) abort(403)
flash('Query result "{}" has been marked for deletion!'.format(query_result), 'result') # noqa flash(f'Query result "{query_result}" marked for deletion!', 'result')
tasks.delete_query_result(query_result_id) tasks.delete_query_result(query_result_id)
return redirect(url_for('services.service', service="corpus_analysis")) return redirect(url_for('services.service', service="corpus_analysis"))

View File

@ -37,7 +37,7 @@ def add_corpus():
abort(500) abort(500)
else: else:
db.session.commit() db.session.commit()
flash('Corpus "{}" added!'.format(corpus.title), 'corpus') flash(f'Corpus "{corpus.title}" added!', 'corpus')
return redirect(url_for('.corpus', corpus_id=corpus.id)) return redirect(url_for('.corpus', corpus_id=corpus.id))
return render_template('corpora/add_corpus.html.j2', form=form, return render_template('corpora/add_corpus.html.j2', form=form,
title='Add corpus') title='Add corpus')
@ -102,7 +102,7 @@ def import_corpus():
corpus.status = 'prepared' corpus.status = 'prepared'
db.session.commit() db.session.commit()
os.remove(archive_file) os.remove(archive_file)
flash('Corpus "{}" imported!'.format(corpus.title), 'corpus') flash(f'Corpus "{corpus.title}" imported!', 'corpus')
return make_response( return make_response(
{'redirect_url': url_for('.corpus', corpus_id=corpus.id)}, 201) {'redirect_url': url_for('.corpus', corpus_id=corpus.id)}, 201)
else: else:
@ -158,7 +158,7 @@ def delete_corpus(corpus_id):
corpus = Corpus.query.get_or_404(corpus_id) corpus = Corpus.query.get_or_404(corpus_id)
if not (corpus.user == current_user or current_user.is_administrator()): if not (corpus.user == current_user or current_user.is_administrator()):
abort(403) abort(403)
flash('Corpus "{}" marked for deletion!'.format(corpus.title), 'corpus') flash(f'Corpus "{corpus.title}" marked for deletion!', 'corpus')
tasks.delete_corpus(corpus_id) tasks.delete_corpus(corpus_id)
return redirect(url_for('main.dashboard')) return redirect(url_for('main.dashboard'))
@ -194,7 +194,7 @@ def add_corpus_file(corpus_id):
db.session.add(corpus_file) db.session.add(corpus_file)
corpus.status = 'unprepared' corpus.status = 'unprepared'
db.session.commit() db.session.commit()
flash('Corpus file "{}" added!'.format(corpus_file.filename), 'corpus') flash(f'Corpus file "{corpus_file.filename}" added!', 'corpus')
return make_response({'redirect_url': url_for('.corpus', corpus_id=corpus.id)}, 201) # noqa return make_response({'redirect_url': url_for('.corpus', corpus_id=corpus.id)}, 201) # noqa
return render_template('corpora/add_corpus_file.html.j2', corpus=corpus, return render_template('corpora/add_corpus_file.html.j2', corpus=corpus,
form=form, title='Add corpus file') form=form, title='Add corpus file')
@ -209,7 +209,8 @@ def delete_corpus_file(corpus_id, corpus_file_id):
if not (corpus_file.corpus.user == current_user if not (corpus_file.corpus.user == current_user
or current_user.is_administrator()): or current_user.is_administrator()):
abort(403) abort(403)
flash('Corpus file "{}" marked for deletion!'.format(corpus_file.filename), 'corpus') # noqa flash(
f'Corpus file "{corpus_file.filename}" marked for deletion!', 'corpus')
tasks.delete_corpus_file(corpus_file_id) tasks.delete_corpus_file(corpus_file_id)
return redirect(url_for('.corpus', corpus_id=corpus_id)) return redirect(url_for('.corpus', corpus_id=corpus_id))
@ -253,7 +254,7 @@ def corpus_file(corpus_id, corpus_file_id):
corpus_file.title = form.title.data corpus_file.title = form.title.data
corpus.status = 'unprepared' corpus.status = 'unprepared'
db.session.commit() db.session.commit()
flash('Corpus file "{}" edited!'.format(corpus_file.filename), 'corpus') # noqa flash(f'Corpus file "{corpus_file.filename}" edited!', 'corpus')
return redirect(url_for('.corpus', corpus_id=corpus_id)) return redirect(url_for('.corpus', corpus_id=corpus_id))
# If no form is submitted or valid, fill out fields with current values # If no form is submitted or valid, fill out fields with current values
form.address.data = corpus_file.address form.address.data = corpus_file.address
@ -273,15 +274,15 @@ def corpus_file(corpus_id, corpus_file_id):
title='Edit corpus file') title='Edit corpus file')
@bp.route('/<hashid:corpus_id>/prepare') @bp.route('/<hashid:corpus_id>/build')
@login_required @login_required
def prepare_corpus(corpus_id): def build_corpus(corpus_id):
corpus = Corpus.query.get_or_404(corpus_id) corpus = Corpus.query.get_or_404(corpus_id)
if not (corpus.user == current_user or current_user.is_administrator()): if not (corpus.user == current_user or current_user.is_administrator()):
abort(403) abort(403)
if corpus.files.all(): if corpus.files.all():
tasks.build_corpus(corpus_id) tasks.build_corpus(corpus_id)
flash('Corpus "{}" has been marked to get build!'.format(corpus.title), 'corpus') # noqa flash(f'Corpus "{corpus.title}" marked for building!', 'corpus')
else: else:
flash('Can not build corpus "{}": No corpus file(s)!'.format(corpus.title), 'error') # noqa flash(f'Can\'t build corpus "{corpus.title}": No corpus file(s)!', 'error') # noqa
return redirect(url_for('.corpus', corpus_id=corpus_id)) return redirect(url_for('.corpus', corpus_id=corpus_id))

View File

@ -9,7 +9,7 @@ def build_corpus(corpus_id, *args, **kwargs):
with app.app_context(): with app.app_context():
corpus = Corpus.query.get(corpus_id) corpus = Corpus.query.get(corpus_id)
if corpus is None: if corpus is None:
raise Exception('Corpus {} not found'.format(corpus_id)) raise Exception(f'Corpus {corpus_id} not found')
corpus.build() corpus.build()
db.session.commit() db.session.commit()
@ -19,7 +19,7 @@ def delete_corpus(corpus_id, *args, **kwargs):
with kwargs['app'].app_context(): with kwargs['app'].app_context():
corpus = Corpus.query.get(corpus_id) corpus = Corpus.query.get(corpus_id)
if corpus is None: if corpus is None:
raise Exception('Corpus {} not found'.format(corpus_id)) raise Exception(f'Corpus {corpus_id} not found')
corpus.delete() corpus.delete()
db.session.commit() db.session.commit()
@ -29,7 +29,7 @@ def delete_corpus_file(corpus_file_id, *args, **kwargs):
with kwargs['app'].app_context(): with kwargs['app'].app_context():
corpus_file = CorpusFile.query.get(corpus_file_id) corpus_file = CorpusFile.query.get(corpus_file_id)
if corpus_file is None: if corpus_file is None:
raise Exception('Corpus file {} not found'.format(corpus_file_id)) raise Exception(f'Corpus file {corpus_file_id} not found')
corpus_file.delete() corpus_file.delete()
db.session.commit() db.session.commit()
@ -39,6 +39,6 @@ def delete_query_result(query_result_id, *args, **kwargs):
with kwargs['app'].app_context(): with kwargs['app'].app_context():
query_result = QueryResult.query.get(query_result_id) query_result = QueryResult.query.get(query_result_id)
if query_result is None: if query_result is None:
raise Exception('QueryResult {} not found'.format(query_result_id)) raise Exception(f'QueryResult {query_result_id} not found')
query_result.delete() query_result.delete()
db.session.commit() db.session.commit()

View File

@ -48,10 +48,10 @@ def download_job_input(job_id, job_input_id):
def restart(job_id): def restart(job_id):
job = Job.query.get_or_404(job_id) job = Job.query.get_or_404(job_id)
if job.status not in ['complete', 'failed']: if job.status not in ['complete', 'failed']:
flash('Can not restart job "{}": Status is not "complete/failed"'.format(job.title), 'error') # noqa flash(f'Can not restart job "{job.title}": Status is not "complete/failed"', 'error') # noqa
else: else:
tasks.restart_job(job_id) tasks.restart_job(job_id)
flash('Job "{}" has been marked to get restarted!'.format(job.title), 'job') # noqa flash(f'Job "{job.title}" marked to get restarted!', 'job')
return redirect(url_for('.job', job_id=job_id)) return redirect(url_for('.job', job_id=job_id))

View File

@ -8,7 +8,7 @@ def delete_job(job_id, *args, **kwargs):
with kwargs['app'].app_context(): with kwargs['app'].app_context():
job = Job.query.get(job_id) job = Job.query.get(job_id)
if job is None: if job is None:
raise Exception('Job {} not found'.format(job_id)) raise Exception(f'Job {job_id} not found')
job.delete() job.delete()
db.session.commit() db.session.commit()
@ -18,7 +18,7 @@ def restart_job(job_id, *args, **kwargs):
with kwargs['app'].app_context(): with kwargs['app'].app_context():
job = Job.query.get(job_id) job = Job.query.get(job_id)
if job is None: if job is None:
raise Exception('Job {} not found'.format(job_id)) raise Exception(f'Job {job_id} not found')
try: try:
job.restart() job.restart()
except Exception: except Exception:

View File

@ -37,11 +37,11 @@ def service(service):
return make_response(form.errors, 400) return make_response(form.errors, 400)
service_args = [] service_args = []
if service == 'nlp': if service == 'nlp':
service_args.append('-l {}'.format(form.language.data)) service_args.append(f'-l {form.language.data}')
if form.check_encoding.data: if form.check_encoding.data:
service_args.append('--check-encoding') service_args.append('--check-encoding')
if service == 'ocr': if service == 'ocr':
service_args.append('-l {}'.format(form.language.data)) service_args.append(f'-l {form.language.data}')
if form.binarization.data: if form.binarization.data:
service_args.append('--binarize') service_args.append('--binarize')
job = Job(user=current_user, job = Job(user=current_user,
@ -55,9 +55,7 @@ def service(service):
try: try:
os.makedirs(job.path) os.makedirs(job.path)
except OSError: except OSError:
current_app.logger.error( current_app.logger.error(f'Make dir {job.path} led to an OSError!')
'Make dir {} led to an OSError!'.format(job.path)
)
db.session.rollback() db.session.rollback()
flash('Internal Server Error', 'error') flash('Internal Server Error', 'error')
return make_response( return make_response(
@ -71,8 +69,12 @@ def service(service):
db.session.add(job_input) db.session.add(job_input)
job.status = 'submitted' job.status = 'submitted'
db.session.commit() db.session.commit()
flash('Job "{}" added'.format(job.title), 'job') flash(f'Job "{job.title}" added', 'job')
return make_response( return make_response(
{'redirect_url': url_for('jobs.job', job_id=job.id)}, 201) {'redirect_url': url_for('jobs.job', job_id=job.id)}, 201)
return render_template('services/{}.html.j2'.format(service.replace('-', '_')), return render_template(
form=form, title=title, versions=versions) f'services/{service.replace("-", "_")}.html.j2',
form=form,
title=title,
versions=versions
)

View File

@ -8,6 +8,6 @@ def delete_user(user_id, *args, **kwargs):
with kwargs['app'].app_context(): with kwargs['app'].app_context():
user = User.query.get(user_id) user = User.query.get(user_id)
if user is None: if user is None:
raise Exception('User {} not found'.format(user_id)) raise Exception(f'User {user_id} not found')
user.delete() user.delete()
db.session.commit() db.session.commit()

View File

@ -65,7 +65,7 @@
</div> </div>
<div class="card-action right-align"> <div class="card-action right-align">
<a class="analyse-corpus-trigger btn disabled waves-effect waves-light" href="{{ url_for('corpora.analyse_corpus', corpus_id=corpus.id) }}"><i class="material-icons left">search</i>Analyze</a> <a class="analyse-corpus-trigger btn disabled waves-effect waves-light" href="{{ url_for('corpora.analyse_corpus', corpus_id=corpus.id) }}"><i class="material-icons left">search</i>Analyze</a>
<a class="btn build-corpus-trigger disabled waves-effect waves-light" href="{{ url_for('corpora.prepare_corpus', corpus_id=corpus.id) }}"><i class="nopaque-icons left">K</i>Build</a> <a class="btn build-corpus-trigger disabled waves-effect waves-light" href="{{ url_for('corpora.build_corpus', corpus_id=corpus.id) }}"><i class="nopaque-icons left">K</i>Build</a>
<a class="btn disabled export-corpus-trigger waves-effect waves-light"><i class="material-icons left">import_export</i>Export</a> <a class="btn disabled export-corpus-trigger waves-effect waves-light"><i class="material-icons left">import_export</i>Export</a>
<a class="btn modal-trigger red waves-effect waves-light" data-target="delete-corpus-modal"><i class="material-icons left">delete</i>Delete</a> <a class="btn modal-trigger red waves-effect waves-light" data-target="delete-corpus-modal"><i class="material-icons left">delete</i>Delete</a>
</div> </div>