def update_latest_web_service_reports_for_organization(self, org_uuid=None):
"""
Update all of the web service reports for the given organization based on the current state of the web
service inspector.
:param org_uuid: The UUID of the organization to update web service reports for.
:return: None
"""
logger.info(
"Now updating all web service reports for organization %s."
% (org_uuid,)
)
report_ids = get_latest_web_service_report_ids(org_uuid)
logger.info(
"Total of %s web service reports found for organization %s."
% (len(report_ids), org_uuid)
)
task_sigs = []
for report_id in report_ids:
task_sigs.append(update_web_service_report_for_organization.si(
doc_id=report_id,
org_uuid=org_uuid,
is_latest=True,
))
canvas_sig = group(task_sigs)
logger.info(
"Kicking off a total of %s tasks to update web service reports for organization %s."
% (len(task_sigs), org_uuid)
)
self.finish_after(signature=canvas_sig)
评论列表
文章目录