code: def fetch_push_logs():
      
      for repo in Repository.objects.filter(dvcs_type='hg',
                                            active_status="active"):
          fetch_hg_push_log.apply_async(
              args=(repo.name, repo.url),
              queue='pushlog'
          )
docs: Run several fetch_hg_push_log subtasks, one per repository