Tasks

The Task classes all have a run() method that will be called by Celery runtime.

List of Tasks

class DataCleanupTask[source]

Delete temporary files that have exceeded their lifetime.

class PipelineTask[source]

Runs a highly configurable pipeline.

class MongoDumpTask[source]

Dump MongoDB collections. Can be restored with the MongoRestoreTask.

class MongoRestoreTask[source]

Restore MongoDB collections from dumps created with the MongoDumpTask.

class RebuildFulltextIndexTask[source]

Rebuilds Elasticsearch indexes and reindexes all data within that indexes with zero downtime.

reassign_alias(alias, index)[source]

Point the alias to the given index.

build_index(index)[source]

Build a new index.

rebuild_index(index)[source]

Rebuild a given index.

contains_index(index, indices)[source]

Check if the index is listed in the given indices.