-
Notifications
You must be signed in to change notification settings - Fork 2.1k
Implement source testing framework + Slack #2650
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
|
||
from tests.integration.connector_job_tests.slack.slack_api_utils import SlackManager | ||
|
||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this makes sure that if the test fails, the slack state gets reset
) -> DATestUser: | ||
if name is None: | ||
name = f"test{str(uuid4())}" | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
added email so exact email can be specified
f"Waiting for CC pruning to complete. elapsed={elapsed:.2f} timeout={timeout}" | ||
) | ||
time.sleep(5) | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this tracks sync progress
if not verify_deleted: | ||
raise ValueError(f"CC pair {cc_pair.id} not found") | ||
|
||
@staticmethod |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this lets us run the connector on demand
|
||
logger = setup_logger() | ||
|
||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
moved this into the celery check
|
||
logger = setup_logger() | ||
|
||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
moved this here to filter without creating a task
register_time=last_sync_task.register_time, | ||
) | ||
|
||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Added a way to start a sync as well as check on sync progress.
This is reusable on the frontend as well if necessary
"group_join", | ||
"group_leave", | ||
"group_archive", | ||
"group_unarchive", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this is necessary to make the tests work. i also dont think this will change the quality of the results but im not sure.
No description provided.