Skip to content

Commit

Permalink
clean up for users to copy
Browse files Browse the repository at this point in the history
  • Loading branch information
bhancockio committed Oct 4, 2024
1 parent 980a3a9 commit 3bdee63
Show file tree
Hide file tree
Showing 12 changed files with 76 additions and 23,981 deletions.
6,361 changes: 0 additions & 6,361 deletions email_auto_responder_flow/poetry.lock

This file was deleted.

5 changes: 3 additions & 2 deletions email_auto_responder_flow/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ authors = ["Your Name <you@example.com>"]

[tool.poetry.dependencies]
python = ">=3.10,<=3.13"
crewai = {path="/Users/brandonhancock/Code/crewai/crewAI", develop=true}
crewai = { extras = ["tools"], version = ">=0.67.1,<1.0.0" }
asyncio = "*"
langchain-tools = "^0.1.34"
crewai-tools = "^0.12.0"
Expand All @@ -15,7 +15,8 @@ google-api-python-client = "^2.145.0"

[tool.poetry.scripts]
email_auto_responder_flow = "email_auto_responder_flow.main:main"
run_crew = "email_auto_responder_flow.main:main"
run_flow = "email_auto_responder_flow.main:main"
plot_flow = "email_auto_responder_flow.main:plot"

[build-system]
requires = ["poetry-core"]
Expand Down
18 changes: 15 additions & 3 deletions email_auto_responder_flow/src/email_auto_responder_flow/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,16 +45,28 @@ def generate_draft_responses(self):
time.sleep(180)


async def run():
async def run_flow():
"""
Run the flow.
"""
email_auto_response_flow = EmailAutoResponderFlow()
await email_auto_response_flow.kickoff()
email_auto_response_flow.kickoff()


async def plot_flow():
"""
Plot the flow.
"""
email_auto_response_flow = EmailAutoResponderFlow()
email_auto_response_flow.plot()


def main():
asyncio.run(run())
asyncio.run(run_flow())


def plot():
asyncio.run(plot_flow())


if __name__ == "__main__":
Expand Down
6,361 changes: 0 additions & 6,361 deletions lead-score-flow/poetry.lock

This file was deleted.

7 changes: 5 additions & 2 deletions lead-score-flow/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -6,16 +6,19 @@ authors = ["Your Name <you@example.com>"]

[tool.poetry.dependencies]
python = ">=3.10,<=3.13"
crewai = {path="/Users/brandonhancock/Code/crewai/crewAI", develop=true}
crewai = { extras = ["tools"], version = ">=0.67.1,<1.0.0" }
asyncio = "*"
langchain-tools = "^0.1.34"
crewai-tools = "^0.12.0"
google-auth-oauthlib = "^1.2.1"
google-api-python-client = "^2.145.0"
pyvis = "^0.3.2"

[tool.poetry.scripts]
lead_score_flow = "lead_score_flow.main:main"
run_crew = "lead_score_flow.main:main"
run_flow = "lead_score_flow.main:main"
plot_flow = "lead_score_flow.main:plot"


[build-system]
requires = ["poetry-core"]
Expand Down
22 changes: 17 additions & 5 deletions lead-score-flow/src/lead_score_flow/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ class LeadScoreState(BaseModel):
scored_leads_feedback: str = ""


class EmailAutoResponderFlow(Flow[LeadScoreState]):
class LeadScoreFlow(Flow[LeadScoreState]):
initial_state = LeadScoreState

@start()
Expand Down Expand Up @@ -186,16 +186,28 @@ async def write_email(candidate):
print(message)


async def run():
async def run_flow():
"""
Run the flow.
"""
email_auto_response_flow = EmailAutoResponderFlow()
await email_auto_response_flow.kickoff()
lead_score_flow = LeadScoreFlow()
lead_score_flow.kickoff()


async def plot_flow():
"""
Plot the flow.
"""
lead_score_flow = LeadScoreFlow()
lead_score_flow.plot()


def main():
asyncio.run(run())
asyncio.run(run_flow())


def plot():
asyncio.run(plot_flow())


if __name__ == "__main__":
Expand Down
5,850 changes: 0 additions & 5,850 deletions meeting_assistant_flow/poetry.lock

This file was deleted.

5 changes: 3 additions & 2 deletions meeting_assistant_flow/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -6,13 +6,14 @@ authors = ["Your Name <you@example.com>"]

[tool.poetry.dependencies]
python = ">=3.10,<=3.13"
crewai = {path="/Users/brandonhancock/Code/crewai/crewAI", develop=true}
crewai = { extras = ["tools"], version = ">=0.67.1,<1.0.0" }
asyncio = "*"
slack-sdk = "^3.33.1"

[tool.poetry.scripts]
meeting_assistant_flow = "meeting_assistant_flow.main:main"
run_crew = "meeting_assistant_flow.main:main"
run_flow = "meeting_assistant_flow.main:main"
plot_flow = "meeting_assistant_flow.main:plot"

[build-system]
requires = ["poetry-core"]
Expand Down
18 changes: 15 additions & 3 deletions meeting_assistant_flow/src/meeting_assistant_flow/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -67,16 +67,28 @@ def send_slack_notification(self):
send_message_to_channel(message)


async def run():
async def run_flow():
"""
Run the flow.
"""
meeting_flow = MeetingFlow()
await meeting_flow.kickoff()
meeting_flow.kickoff()


async def plot_flow():
"""
Plot the flow.
"""
meeting_flow = MeetingFlow()
meeting_flow.plot()


def main():
asyncio.run(run())
asyncio.run(run_flow())


def plot():
asyncio.run(plot_flow())


if __name__ == "__main__":
Expand Down
5,387 changes: 0 additions & 5,387 deletions write_a_book_with_flows/poetry.lock

This file was deleted.

5 changes: 3 additions & 2 deletions write_a_book_with_flows/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,13 @@ authors = ["Your Name <you@example.com>"]

[tool.poetry.dependencies]
python = ">=3.10,<=3.13"
crewai = {path="/Users/brandonhancock/Code/crewai/crewAI", extras = ["tools"]}
crewai = { extras = ["tools"], version = ">=0.67.1,<1.0.0" }
asyncio = "*"

[tool.poetry.scripts]
write_a_book_with_flows = "write_a_book_with_flows.main:main"
run_crew = "write_a_book_with_flows.main:main"
run_flow = "write_a_book_with_flows.main:main"
plot_flow = "write_a_book_with_flows.main:plot"

[build-system]
requires = ["poetry-core"]
Expand Down
18 changes: 15 additions & 3 deletions write_a_book_with_flows/src/write_a_book_with_flows/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -115,16 +115,28 @@ async def join_and_save_chapter(self):
return book_content


async def run():
async def run_flow():
"""
Run the flow.
"""
book_flow = BookFlow()
await book_flow.kickoff()
book_flow.kickoff()


async def plot_flow():
"""
Plot the flow.
"""
book_flow = BookFlow()
book_flow.plot()


def main():
asyncio.run(run())
asyncio.run(run_flow())


def plot():
asyncio.run(plot_flow())


if __name__ == "__main__":
Expand Down

0 comments on commit 3bdee63

Please sign in to comment.