Skip to content
GitLab
Explore
Sign in
Register
Primary navigation
Search or go to…
Project
B
Base Worker
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Build
Pipelines
Jobs
Pipeline schedules
Artifacts
Deploy
Releases
Package registry
Container Registry
Model registry
Operate
Environments
Terraform modules
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
Workers
Base Worker
Merge requests
!403
Blast Reporter class and usage
Code
Review changes
Check out branch
Download
Patches
Plain diff
Merged
Blast Reporter class and usage
remove-reporter-class
into
master
Overview
1
Commits
1
Pipelines
1
Changes
14
Merged
Eva Bardou
requested to merge
remove-reporter-class
into
master
1 year ago
Overview
1
Commits
1
Pipelines
1
Changes
14
Expand
Closes
#233 (closed)
0
0
Merge request reports
Compare
master
master (base)
and
latest version
latest version
18a1b556
1 commit,
1 year ago
14 files
+
9
−
728
Inline
Compare changes
Side-by-side
Inline
Show whitespace changes
Show one file at a time
Files
14
Search (e.g. *.vue) (Ctrl+P)
arkindex_worker/worker/__init__.py
+
3
−
13
Options
@@ -15,7 +15,6 @@ from apistar.exceptions import ErrorResponse
from
arkindex_worker
import
logger
from
arkindex_worker.cache
import
CachedElement
from
arkindex_worker.models
import
Element
from
arkindex_worker.reporting
import
Reporter
from
arkindex_worker.worker.base
import
BaseWorker
from
arkindex_worker.worker.classification
import
ClassificationMixin
from
arkindex_worker.worker.element
import
ElementMixin
@@ -156,17 +155,12 @@ class ElementsWorker(
super
().
configure
()
super
().
configure_cache
()
# Add report concerning elements
self
.
report
=
Reporter
(
**
self
.
worker_details
,
version
=
getattr
(
self
,
"
worker_version_id
"
,
None
)
)
def
run
(
self
):
"""
Implements an Arkindex worker that goes through each element returned by
[list_elements][arkindex_worker.worker.ElementsWorker.list_elements].
It calls [process_element][arkindex_worker.worker.ElementsWorker.process_element], catching exceptions
and reporting them using the [Reporter
][arkindex_worker.
reporting.Rep
or
t
er
], and handles saving the report
once the process is complete as well as
WorkerActivity updates when enabled.
[list_elements][arkindex_worker.worker.ElementsWorker.list_elements].
It calls [process_element
][arkindex_worker.
worker.ElementsW
or
k
er
.process_element],
catching exceptions, and handles saving
WorkerActivity updates when enabled.
"""
self
.
configure
()
@@ -232,10 +226,6 @@ class ElementsWorker(
self
.
update_activity
(
element
.
id
,
ActivityState
.
Error
)
except
Exception
:
pass
self
.
report
.
error
(
element_id
,
e
)
# Save report as local artifact
self
.
report
.
save
(
self
.
work_dir
/
"
ml_report.json
"
)
if
failed
:
logger
.
error
(
Loading