Use tractor.run_daemon() for pikerd
							parent
							
								
									e108bc4521
								
							
						
					
					
						commit
						82c8fca983
					
				| 
						 | 
					@ -28,14 +28,13 @@ def pikerd(loglevel, host):
 | 
				
			||||||
    """Spawn the piker daemon.
 | 
					    """Spawn the piker daemon.
 | 
				
			||||||
    """
 | 
					    """
 | 
				
			||||||
    get_console_log(loglevel)
 | 
					    get_console_log(loglevel)
 | 
				
			||||||
    tractor.run(
 | 
					    tractor.run_daemon(
 | 
				
			||||||
        partial(trio.sleep, float('inf')),  # daemon / arbiter
 | 
					        rpc_module_paths=['piker.brokers.core'],
 | 
				
			||||||
        statespace={
 | 
					        statespace={
 | 
				
			||||||
            'broker2tickersubs': {},
 | 
					            'broker2tickersubs': {},
 | 
				
			||||||
            'clients': {},
 | 
					            'clients': {},
 | 
				
			||||||
            'dtasks': set(),
 | 
					            'dtasks': set(),
 | 
				
			||||||
        },
 | 
					        },
 | 
				
			||||||
        rpc_module_paths=['piker.brokers.core'],
 | 
					 | 
				
			||||||
        name='brokerd',
 | 
					        name='brokerd',
 | 
				
			||||||
        loglevel=loglevel,
 | 
					        loglevel=loglevel,
 | 
				
			||||||
    )
 | 
					    )
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue