def execute(self, input_data):

        # Grab the Bro log handles from the input
        bro_logs = input_data['pcap_bro']

        # DNS log
        stream = self.workbench.stream_sample(bro_logs['dns_log'])
        self.dns_log_graph(stream)

        # Weird log
        if 'weird_log' in bro_logs:
            stream = self.workbench.stream_sample(bro_logs['weird_log'])
            self.weird_log_graph(stream)

        # HTTP log
        gsleep()
        stream = self.workbench.stream_sample(bro_logs['http_log'])
        self.http_log_graph(stream)

        # Files log
        gsleep()
        stream = self.workbench.stream_sample(bro_logs['files_log'])
        self.files_log_graph(stream)

        # Conn log
        # Conn log can be big; skipping for now
        '''
        gsleep()
        stream = self.workbench.stream_sample(bro_logs['conn_log'])
        self.conn_log_graph(stream)
        '''

        return {'output':'go to http://localhost:7474/browser and execute this query "match (s:origin), (t:file), p=allShortestPaths((s)--(t)) return p"'}
Create a new item. The creator will be given admin access to it.
dataset/ETHPy150Open SuperCowPowers/workbench/workbench/workers/pcap_graph.py/PcapGraph.execute--crossover with--dataset/ETHPy150Open girder/girder/girder/models/item.py/Item.createItem