Changeset View
Changeset View
Standalone View
Standalone View
swh/indexer/tasks.py
# Copyright (C) 2016-2020 The Software Heritage developers | # Copyright (C) 2016-2020 The Software Heritage developers | ||||
# See the AUTHORS file at the top-level directory of this distribution | # See the AUTHORS file at the top-level directory of this distribution | ||||
# License: GNU General Public License version 3, or any later version | # License: GNU General Public License version 3, or any later version | ||||
# See top-level LICENSE file for more information | # See top-level LICENSE file for more information | ||||
from celery import current_app as app | from celery import current_app as app | ||||
from .mimetype import MimetypeIndexer, MimetypeRangeIndexer | from .mimetype import MimetypeIndexer, MimetypePartitionIndexer | ||||
from .ctags import CtagsIndexer | from .ctags import CtagsIndexer | ||||
from .fossology_license import FossologyLicenseIndexer, FossologyLicenseRangeIndexer | from .fossology_license import FossologyLicenseIndexer, FossologyLicensePartitionIndexer | ||||
from .rehash import RecomputeChecksums | from .rehash import RecomputeChecksums | ||||
from .metadata import OriginMetadataIndexer | from .metadata import OriginMetadataIndexer | ||||
@app.task(name=__name__ + ".OriginMetadata") | @app.task(name=__name__ + ".OriginMetadata") | ||||
def origin_metadata(*args, **kwargs): | def origin_metadata(*args, **kwargs): | ||||
return OriginMetadataIndexer().run(*args, **kwargs) | return OriginMetadataIndexer().run(*args, **kwargs) | ||||
Show All 15 Lines | |||||
@app.task(name=__name__ + ".ContentMimetype") | @app.task(name=__name__ + ".ContentMimetype") | ||||
def mimetype(*args, **kwargs): | def mimetype(*args, **kwargs): | ||||
return MimetypeIndexer().run(*args, **kwargs) | return MimetypeIndexer().run(*args, **kwargs) | ||||
@app.task(name=__name__ + ".ContentRangeMimetype") | @app.task(name=__name__ + ".ContentRangeMimetype") | ||||
def range_mimetype(*args, **kwargs): | def range_mimetype(*args, **kwargs): | ||||
return MimetypeRangeIndexer().run(*args, **kwargs) | return MimetypePartitionIndexer().run(*args, **kwargs) | ||||
@app.task(name=__name__ + ".ContentRangeFossologyLicense") | @app.task(name=__name__ + ".ContentRangeFossologyLicense") | ||||
def range_license(*args, **kwargs): | def range_license(*args, **kwargs): | ||||
return FossologyLicenseRangeIndexer().run(*args, **kwargs) | return FossologyLicensePartitionIndexer().run(*args, **kwargs) |