old_contents: """Tasks to perform periodic tasks with remotes."""
  
  from celery.utils.log import get_task_logger
  
  from freelancefinder import celery_app
  from .models import Source
  
  logger = get_task_logger(__name__)
  
  
  @celery_app.task
  def harvest_sources():
      """Get a new batch of data from all sources."""
      for source in Source.objects.all():
          logger.info("Harvesting from Source: %s", source)
          harvester = source.harvester()
          for post in harvester.harvest():
              logger.info("Got new Post: %s", post)
  
new_contents: """Tasks to perform periodic tasks with remotes."""
  
  from celery import shared_task
  from celery.utils.log import get_task_logger
  
  from .models import Source
  
  logger = get_task_logger(__name__)
  
  
  @shared_task
  def harvest_sources():
      """Get a new batch of data from all sources."""
      for source in Source.objects.all():
          logger.info("Harvesting from Source: %s", source)
          harvester = source.harvester()
          for post in harvester.harvest():
              logger.info("Got new Post: %s", post)
  
subject: use shared_task decorator