slack-bridge: Use threading instead of multiprocessing.
This will fix the bug reported in https://chat.zulip.org/#narrow/stream/127-integrations/topic/bridge_with_slack/near/1182555, which is specific to macOS. The error message is ``` AttributeError: Can't pickle local object 'SlackBridge.zulip_to_slack.<locals>._zulip_to_slack' ```
This commit is contained in:
		
							parent
							
								
									2d9cf64db8
								
							
						
					
					
						commit
						5b2da94ba5
					
				
					 1 changed files with 3 additions and 3 deletions
				
			
		| 
						 | 
					@ -5,7 +5,7 @@ import sys
 | 
				
			||||||
import os
 | 
					import os
 | 
				
			||||||
import argparse
 | 
					import argparse
 | 
				
			||||||
import traceback
 | 
					import traceback
 | 
				
			||||||
import multiprocessing as mp
 | 
					import threading
 | 
				
			||||||
import zulip
 | 
					import zulip
 | 
				
			||||||
import slack_sdk
 | 
					import slack_sdk
 | 
				
			||||||
from slack_sdk.rtm import RTMClient
 | 
					from slack_sdk.rtm import RTMClient
 | 
				
			||||||
| 
						 | 
					@ -123,8 +123,8 @@ if __name__ == "__main__":
 | 
				
			||||||
        try:
 | 
					        try:
 | 
				
			||||||
            sb = SlackBridge(config)
 | 
					            sb = SlackBridge(config)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            zp = mp.Process(target=sb.zulip_client.call_on_each_message, args=(sb.zulip_to_slack(),))
 | 
					            zp = threading.Thread(target=sb.zulip_client.call_on_each_message, args=(sb.zulip_to_slack(),))
 | 
				
			||||||
            sp = mp.Process(target=sb.run_slack_listener, args=())
 | 
					            sp = threading.Thread(target=sb.run_slack_listener, args=())
 | 
				
			||||||
            print("Starting message handler on Zulip client")
 | 
					            print("Starting message handler on Zulip client")
 | 
				
			||||||
            zp.start()
 | 
					            zp.start()
 | 
				
			||||||
            print("Starting message handler on Slack client")
 | 
					            print("Starting message handler on Slack client")
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue