File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -83,7 +83,7 @@ def _create_subscription_process(
8383 self ._cleanup_connections_and_processes ()
8484
8585 self .parent_conn , self .child_conn = Pipe ()
86- self .subscription_proces = Process (
86+ self .subscription_process = Process (
8787 target = casbin_channel_subscription ,
8888 args = (
8989 self .child_conn ,
@@ -109,9 +109,9 @@ def start(
109109 self ,
110110 timeout = 20 , # seconds
111111 ):
112- if not self .subscription_proces .is_alive ():
112+ if not self .subscription_process .is_alive ():
113113 # Start listening to messages
114- self .subscription_proces .start ()
114+ self .subscription_process .start ()
115115 # And wait for the Process to be ready to listen for updates
116116 # from PostgreSQL
117117 timeout_time = time () + timeout
Original file line number Diff line number Diff line change @@ -50,7 +50,7 @@ def test_pg_watcher_init(self):
5050 assert isinstance (pg_watcher .parent_conn , connection .PipeConnection )
5151 else :
5252 assert isinstance (pg_watcher .parent_conn , connection .Connection )
53- assert isinstance (pg_watcher .subscription_proces , context .Process )
53+ assert isinstance (pg_watcher .subscription_process , context .Process )
5454
5555 def test_update_single_pg_watcher (self ):
5656 pg_watcher = get_watcher ("test_update_single_pg_watcher" )
You can’t perform that action at this time.
0 commit comments