<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def fetch_push_logs():
 """ Run several fetch_hg_push_log subtasks, one per repository """

    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'
        )