External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-03-07 19:51:08 -03:30
Code Issues Packages Projects Releases Wiki Activity

Add some stdout to the activity stream cleanup command

Browse Source
This commit is contained in:
Matthew Jones
2014-12-16 10:05:14 -05:00
parent feaee64706
commit b0d6628d46
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
awx/main/management/commands/cleanup_activitystream.py
View File

@@ -41,6 +41,7 @@ class Command(NoArgsCommand):
self.logger.propagate = False self.logger.propagate = False
def cleanup_activitystream(self): def cleanup_activitystream(self):
n_deleted_items = 0
for asobj in ActivityStream.objects.all(): for asobj in ActivityStream.objects.all():
asobj_disp = '"%s" id: %s' % (unicode(asobj), asobj.id) asobj_disp = '"%s" id: %s' % (unicode(asobj), asobj.id)
if asobj.timestamp >= self.cutoff: if asobj.timestamp >= self.cutoff:
@@ -51,6 +52,8 @@ class Command(NoArgsCommand):
self.logger.info("would delete %s" % asobj_disp) self.logger.info("would delete %s" % asobj_disp)
if not self.dry_run: if not self.dry_run:
asobj.delete() asobj.delete()
n_deleted_items += 1
print("Removed %s items" % str(n_deleted_items))
def handle_noargs(self, **options): def handle_noargs(self, **options):
self.verbosity = int(options.get('verbosity', 1)) self.verbosity = int(options.get('verbosity', 1))