Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
Signed-off-by: Kevin Su <[email protected]>
  • Loading branch information
pingsutw committed Apr 23, 2024
1 parent 28d4fa5 commit d9fa22d
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 7 deletions.
3 changes: 2 additions & 1 deletion .github/workflows/checks_new.yml
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,10 @@ jobs:
- name: "Provide the list"
id: create-example-list
run: |
# TODO: Register and update the examples below. (onnx_plugin, feast_integration, etc)
echo "PACKAGES=$(find examples -maxdepth 1 -type d -exec basename '{}' \; \
| grep -v -e 'testing' -e 'examples' \
| grep -v -e 'airflow_plugin' -e 'forecasting_sales' -e 'onnx_plugin' -e 'feast_integration' -e 'modin_plugin' -e 'sagemaker_inference_agent' -e 'kfpytorch_plugin' -e 'extending' \
| grep -v -e 'airflow_plugin' -e 'forecasting_sales' -e 'onnx_plugin' -e 'feast_integration' -e 'modin_plugin' -e 'sagemaker_inference_agent' -e 'kfpytorch_plugin'' \
| sort \
| jq --raw-input . \
| jq --slurp . \
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -130,14 +130,14 @@ def post_message_on_slack(message: str):


@workflow
def wf(owner: str = "flyteorg", repo: str = "flyte", channel: str = "demo"):
def slack_wf(owner: str = "flyteorg", repo: str = "flyte", channel: str = "demo"):
message = get_github_latest_release(owner=owner, repo=repo)
message = chatgpt_job(message=message)
post_message_on_slack(message=message)


if __name__ == "__main__":
wf()
slack_wf()


# %% [markdown]
Expand Down Expand Up @@ -183,7 +183,7 @@ def get_latest_video_transcript_chunks(channel_url: str) -> List[str]:


@workflow
def wf(channel_url: str):
def video_wf(channel_url: str):
chunks = get_latest_video_transcript_chunks(channel_url=channel_url)
dynamic_subwf(channel_url=channel_url, chunks=chunks)

Expand Down Expand Up @@ -268,7 +268,7 @@ def dynamic_subwf(channel_url: str, chunks: List[str]):


if __name__ == "__main__":
wf(channel_url="https://www.youtube.com/@flyteorg")
video_wf(channel_url="https://www.youtube.com/@flyteorg")

# %% [markdown]
# ### Summarize the latest MLOps trend from Medium to Twitter
Expand Down Expand Up @@ -353,11 +353,11 @@ def tweet(text: str):


@workflow
def wf(url: str = "https://medium.com/tag/flyte"):
def tweet_wf(url: str = "https://medium.com/tag/flyte"):
message = get_weekly_articles_title(url=url)
message = chatgpt_job(message=message)
tweet(text=message)


if __name__ == "__main__":
wf()
tweet_wf()

0 comments on commit d9fa22d

Please sign in to comment.