highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-06-22 14:00:57 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix Pull vs Poll naming (#77)

Browse Source
This commit is contained in:
Yuhong Sun 2023-05-22 11:29:50 -07:00 committed by GitHub
parent 0c4dcb13c3
commit 8e9e284849
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
backend/danswer/connectors/slack/connector.py
View File

@ -251,13 +251,17 @@ def _process_batch_event(
class SlackConnector(LoadConnector, PollConnector): class SlackConnector(LoadConnector, PollConnector):
def __init__( def __init__(
self, export_path_str: str, batch_size: int = INDEX_BATCH_SIZE self, export_path_str: str | None = None, batch_size: int = INDEX_BATCH_SIZE
) -> None: ) -> None:
self.export_path_str = export_path_str self.export_path_str = export_path_str
self.batch_size = batch_size self.batch_size = batch_size
self.client = get_client() self.client = get_client()
def load_from_state(self) -> Generator[list[Document], None, None]: def load_from_state(self) -> Generator[list[Document], None, None]:
if self.export_path_str is None:
raise ValueError(
"This Slack connector was not set up with a state-export file."
)
export_path = Path(self.export_path_str) export_path = Path(self.export_path_str)
with open(export_path / "channels.json") as f: with open(export_path / "channels.json") as f: