kamikazechaser/cic-internal-integration
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Prune useless lines from graph script

Browse Source
This commit is contained in:
nolash 2021-04-25 14:04:32 +02:00
parent 425bd184df
commit 2e3f80a3f4
Signed by untrusted user who does not match committer: lash
GPG Key ID: 21D2E7BB88C2A746
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
apps/contract-migration/scripts/cic_eth/paths.py
View File

@ -28,8 +28,9 @@ class Fmtr(celery.utils.graph.GraphFormatter):
def label(self, obj):
super(Fmtr, self).label(obj)
if obj != None:
logg.debug('obj {} attrs'.format(obj.id))
return obj.queue
if obj.name == None:
raise RuntimeError('task name is not defined. Did you run celery with result_extended=True?')
return obj.name
def main():
@ -41,12 +42,8 @@ def main():
#callback_queue=args.q,
)
t = api.create_account(register=False)
for e in t.collect():
print(e[0].backend.get('celery-task-meta-{}'.format(e[0].id)))
print(e[0].name)
#t.build_graph(intermediate=True, formatter=Fmtr()).to_dot(sys.stdout)ka
#v = celery_app.control.inspect().query_task(t.id).objgraph()
#v = celery_app.control.inspect().stats()
t.get_leaf()
t.build_graph(intermediate=True, formatter=Fmtr()).to_dot(sys.stdout)
if __name__ == '__main__':