old_contents: from celery.task import task
  
  from elasticgit import EG
  from unicore.content.models import Page, Category, Localisation
  
  
  @task(ignore_result=True, serializer='json')
  def fastforward(repo_path, index_prefix):
      workspace = EG.workspace(repo_path, index_prefix=index_prefix)
      workspace.fast_forward()
      workspace.reindex(Page)
      workspace.reindex(Category)
      workspace.reindex(Localisation)
  
new_contents: from pyramid_celery import celery_app as app
  
  from elasticgit import EG
  from unicore.content.models import Page, Category, Localisation
  
  
  @app.task(ignore_result=True, serializer='json')
  def fastforward(repo_path, index_prefix):
      workspace = EG.workspace(repo_path, index_prefix=index_prefix)
      workspace.fast_forward()
      workspace.reindex(Page)
      workspace.reindex(Category)
      workspace.reindex(Localisation)
  
subject: make sure pyramid tasks load celery with the correct config