Release 2.3.3 (#325)

* remove logs

* remove requirements

* Bump version

* Squash

* CrewAI enhancements v2 (#324)

* CrewAI improvements

* bump version

Author: karthikscale3

src/examples/crewai_example/instagram_post/__init__.py

@@ -0,0 +1,96 @@
+from crewai import Agent
+from tools.browser_tools import scrape_and_summarize_website
+from langchain_openai import ChatOpenAI
+# from langchain.llms import Ollama
+
+
+class MarketingAnalysisAgents:
+    def __init__(self):
+        # self.llm = Ollama(model=os.environ["MODEL"])
+        self.llm = ChatOpenAI(model_name="gpt-4", temperature=0.7)
+
+    def product_competitor_agent(self):
+        return Agent(
+            role="Lead Market Analyst",
+            goal="""\
+                Conduct amazing analysis of the products and
+                competitors, providing in-depth insights to guide
+                marketing strategies.""",
+            backstory="""\
+                As the Lead Market Analyst at a premier
+                digital marketing firm, you specialize in dissecting
+                online business landscapes.""",
+            tools=[scrape_and_summarize_website],
+            allow_delegation=False,
+            llm=self.llm,
+            verbose=True,
+        )
+
+    def strategy_planner_agent(self):
+        return Agent(
+            role="Chief Marketing Strategist",
+            goal="""\
+                Synthesize amazing insights from product analysis
+                to formulate incredible marketing strategies.""",
+            backstory="""\
+                You are the Chief Marketing Strategist at
+                a leading digital marketing agency, known for crafting
+                bespoke strategies that drive success.""",
+            tools=[scrape_and_summarize_website],
+            llm=self.llm,
+            verbose=True,
+        )
+
+    def creative_content_creator_agent(self):
+        return Agent(
+            role="Creative Content Creator",
+            goal="""\
+                Develop compelling and innovative content
+                for social media campaigns, with a focus on creating
+                high-impact Instagram ad copies.""",
+            backstory="""\
+                As a Creative Content Creator at a top-tier
+                digital marketing agency, you excel in crafting narratives
+                that resonate with audiences on social media.
+                Your expertise lies in turning marketing strategies
+                into engaging stories and visual content that capture
+                attention and inspire action.""",
+            tools=[scrape_and_summarize_website],
+            llm=self.llm,
+            verbose=True,
+        )
+
+    def senior_photographer_agent(self):
+        return Agent(
+            role="Senior Photographer",
+            goal="""\
+            Take the most amazing photographs for instagram ads that
+            capture emotions and convey a compelling message.""",
+            backstory="""\
+            As a Senior Photographer at a leading digital marketing
+            agency, you are an expert at taking amazing photographs that
+            inspire and engage, you're now working on a new campaign for a super
+            important customer and you need to take the most amazing photograph.""",
+            tools=[scrape_and_summarize_website],
+            llm=self.llm,
+            allow_delegation=False,
+            verbose=True,
+        )
+
+    def chief_creative_diretor_agent(self):
+        return Agent(
+            role="Chief Creative Director",
+            goal="""\
+                Oversee the work done by your team to make sure it's the best
+                possible and aligned with the product's goals, review, approve,
+                ask clarifying question or delegate follow up work if necessary to make
+                decisions""",
+            backstory="""\
+                You're the Chief Content Officer of leading digital
+                marketing specialized in product branding. You're working on a new
+                customer, trying to make sure your team is crafting the best possible
+                content for the customer.""",
+            tools=[scrape_and_summarize_website],
+            llm=self.llm,
+            verbose=True,
+        )

src/examples/crewai_example/instagram_post/agents.py

@@ -0,0 +1,80 @@
+
+from dotenv import load_dotenv
+
+load_dotenv()
+
+
+from langtrace_python_sdk import langtrace
+
+langtrace.init()
+
+from crewai import Crew
+from agents import MarketingAnalysisAgents
+from tasks import MarketingAnalysisTasks
+
+tasks = MarketingAnalysisTasks()
+agents = MarketingAnalysisAgents()
+
+print("## Welcome to the marketing Crew")
+print('-------------------------------')
+product_website = "https://langtrace.ai"
+product_details = "LLM App monitoring"
+
+
+# Create Agents
+product_competitor_agent = agents.product_competitor_agent()
+# strategy_planner_agent = agents.strategy_planner_agent()
+# creative_agent = agents.creative_content_creator_agent()
+# # Create Tasks
+website_analysis = tasks.product_analysis(product_competitor_agent, product_website, product_details)
+# market_analysis = tasks.competitor_analysis(product_competitor_agent, product_website, product_details)
+# campaign_development = tasks.campaign_development(strategy_planner_agent, product_website, product_details)
+# write_copy = tasks.instagram_ad_copy(creative_agent)
+
+# Create Crew responsible for Copy
+copy_crew = Crew(
+    agents=[
+        product_competitor_agent,
+        # strategy_planner_agent,
+        # creative_agent
+    ],
+    tasks=[
+        website_analysis,
+        # market_analysis,
+        # campaign_development,
+        # write_copy
+    ],
+    verbose=True
+)
+
+ad_copy = copy_crew.kickoff()
+
+# Create Crew responsible for Image
+# senior_photographer = agents.senior_photographer_agent()
+# chief_creative_diretor = agents.chief_creative_diretor_agent()
+# # Create Tasks for Image
+# take_photo = tasks.take_photograph_task(senior_photographer, ad_copy, product_website, product_details)
+# approve_photo = tasks.review_photo(chief_creative_diretor, product_website, product_details)
+
+# image_crew = Crew(
+#     agents=[
+#         senior_photographer,
+#         chief_creative_diretor
+#     ],
+#     tasks=[
+#         take_photo,
+#         approve_photo
+#     ],
+#     verbose=True
+# )
+
+# image = image_crew.kickoff()
+
+# Print results
+print("\n\n########################")
+print("## Here is the result")
+print("########################\n")
+print("Your post copy:")
+print(ad_copy)
+# print("'\n\nYour midjourney description:")
+# print(image)

src/examples/crewai_example/instagram_post/main.py

@@ -0,0 +1,146 @@
+from crewai import Task
+from textwrap import dedent
+
+
+class MarketingAnalysisTasks:
+    def product_analysis(self, agent, product_website, product_details):
+        return Task(
+            description=dedent(
+                f"""\
+            Analyze the given product website: {product_website}.
+            Extra details provided by the customer: {product_details}.
+
+            Focus on identifying unique features, benefits,
+            and the overall narrative presented.
+
+            Your final report should clearly articulate the
+            product's key selling points, its market appeal,
+            and suggestions for enhancement or positioning.
+            Emphasize the aspects that make the product stand out.
+
+            Keep in mind, attention to detail is crucial for
+            a comprehensive analysis. It's currenlty 2024.
+            """
+            ),
+            agent=agent,
+            expected_output="A detailed analysis of the product website, highlighting key features, benefits, and market positioning.",
+        )
+
+    def competitor_analysis(self, agent, product_website, product_details):
+        return Task(
+            description=dedent(
+                f"""\
+            Explore competitor of: {product_website}.
+            Extra details provided by the customer: {product_details}.
+
+            Identify the top 3 competitors and analyze their
+            strategies, market positioning, and customer perception.
+
+            Your final report MUST include BOTH all context about {product_website}
+            and a detailed comparison to whatever competitor they have competitors.
+            """
+            ),
+            agent=agent,
+            expected_output="A comprehensive analysis of the top 3 competitors, including their strategies, market positioning, and customer perception.",
+        )
+
+    def campaign_development(self, agent, product_website, product_details):
+        return Task(
+            description=dedent(
+                f"""\
+            You're creating a targeted marketing campaign for: {product_website}.
+            Extra details provided by the customer: {product_details}.
+
+            To start this campaing we will need a strategy and creative content ideas.
+            It should be meticulously designed to captivate and engage
+            the product's target audience.
+
+            Based on your ideas your co-workers will create the content for the campaign.
+
+            Your final answer MUST be ideas that will resonate with the audience and
+            also include ALL context you have about the product and the customer.
+            """
+            ),
+            agent=agent,
+            expected_output="A detailed marketing campaign strategy, including creative content ideas and target audience analysis.",
+        )
+
+    def instagram_ad_copy(self, agent):
+        return Task(
+            description=dedent(
+                """\
+            Craft an engaging Instagram post copy.
+            The copy should be punchy, captivating, concise,
+            and aligned with the product marketing strategy.
+
+            Focus on creating a message that resonates with
+            the target audience and highlights the product's
+            unique selling points.
+
+            Your ad copy must be attention-grabbing and should
+            encourage viewers to take action, whether it's
+            visiting the website, making a purchase, or learning
+            more about the product.
+
+            Your final answer MUST be 3 options for an ad copy for instagram that
+            not only informs but also excites and persuades the audience.
+            """
+            ),
+            agent=agent,
+            expected_output="Three engaging Instagram ad copies that align with the product marketing strategy.",
+        )
+
+    def take_photograph_task(self, agent, copy, product_website, product_details):
+        return Task(
+            description=dedent(
+                f"""\
+            You are working on a new campaign for a super important customer,
+            and you MUST take the most amazing photo ever for an instagram post
+            regarding the product, you have the following copy:
+            {copy}
+
+            This is the product you are working with: {product_website}.
+            Extra details provided by the customer: {product_details}.
+
+            Imagine what the photo you wanna take describe it in a paragraph.
+            Here are some examples for you follow:
+            - high tech airplaine in a beautiful blue sky in a beautiful sunset super cripsy beautiful 4k, professional wide shot
+            - the last supper, with Jesus and his disciples, breaking bread, close shot, soft lighting, 4k, crisp
+            - an bearded old man in the snows, using very warm clothing, with mountains full of snow behind him, soft lighting, 4k, crisp, close up to the camera
+
+            Think creatively and focus on how the image can capture the audience's
+            attention. Don't show the actual product on the photo.
+
+            Your final answer must be 3 options of photographs, each with 1 paragraph
+            describing the photograph exactly like the examples provided above.
+            """
+            ),
+            agent=agent,
+            expected_output="Three high-quality photographs that creatively capture the essence of the product and engage the audience.",
+        )
+
+    def review_photo(self, agent, product_website, product_details):
+        return Task(
+            description=dedent(
+                f"""\
+            Review the photos you got from the senior photographer.
+            Make sure it's the best possible and aligned with the product's goals,
+            review, approve, ask clarifying question or delegate follow up work if
+            necessary to make decisions. When delegating work send the full draft
+            as part of the information.
+
+            This is the product you are working with: {product_website}.
+            Extra details provided by the customer: {product_details}.
+
+            Here are some examples on how the final photographs should look like:
+            - high tech airplaine in a beautiful blue sky in a beautiful sunset super cripsy beautiful 4k, professional wide shot
+            - the last supper, with Jesus and his disciples, breaking bread, close shot, soft lighting, 4k, crisp
+            - an bearded old man in the snows, using very warm clothing, with mountains full of snow behind him, soft lighting, 4k, crisp, close up to the camera
+
+            Your final answer must be 3 reviewed options of photographs,
+            each with 1 paragraph description following the examples provided above.
+            """
+            ),
+            agent=agent,
+            expected_output="Three reviewed photographs that align with the product's goals and meet the required standards.",
+        )

src/examples/crewai_example/instagram_post/tasks.py

@@ -0,0 +1,40 @@
+import json
+import os
+
+import requests
+from crewai import Agent, Task
+from crewai_tools import tool
+from unstructured.partition.html import partition_html
+
+from langchain_openai import ChatOpenAI
+
+
+@tool
+def scrape_and_summarize_website(website):
+    """Useful to scrape and summarize a website content, just pass a string with
+    only the full url, no need for a final slash `/`, eg: https://google.com or https://clearbit.com/about-us"""
+    url = f"https://chrome.browserless.io/content?token={os.environ['BROWSERLESS_API_KEY']}"
+    payload = json.dumps({"url": website})
+    headers = {'cache-control': 'no-cache', 'content-type': 'application/json'}
+    response = requests.request("POST", url, headers=headers, data=payload)
+    elements = partition_html(text=response.text)
+    content = "\n\n".join([str(el) for el in elements])
+    content = [content[i:i + 8000] for i in range(0, len(content), 8000)]
+    summaries = []
+    for chunk in content:
+        agent = Agent(
+            role='Principal Researcher',
+            goal='Do amazing researches and summaries based on the content you are working with',
+            backstory="You're a Principal Researcher at a big company and you need to do a research about a given topic.",
+            # llm=Ollama(model=os.environ['MODEL']),
+            llm=ChatOpenAI(model_name="gpt-4", temperature=0.7),
+            allow_delegation=False)
+        task = Task(
+            agent=agent,
+            description=f'Analyze and make a LONG summary the content bellow, make sure to include the ALL relevant information in the summary, return only the summary nothing else.\n\nCONTENT\n----------\n{chunk}',
+            expected_output='A long summary of the content',
+        )
+        summary = task.execute_sync()
+        summaries.append(summary)
+        content = "\n\n".join(summaries)
+    return f'\nScrapped Content: {content}\n'

src/examples/crewai_example/instagram_post/tools/__init__.py

@@ -39,6 +39,21 @@ def _instrument(self, **kwargs):
                 "Crew.kickoff",
                 patch_crew("Crew.kickoff", version, tracer),
             )
+            _W(
+                "crewai.crew",
+                "Crew.kickoff_for_each",
+                patch_crew("Crew.kickoff_for_each", version, tracer),
+            )
+            _W(
+                "crewai.crew",
+                "Crew.kickoff_async",
+                patch_crew("Crew.kickoff_async", version, tracer),
+            )
+            _W(
+                "crewai.crew",
+                "Crew.kickoff_for_each_async",
+                patch_crew("Crew.kickoff_for_each_async", version, tracer),
+            )
             _W(
                 "crewai.agent",
                 "Agent.execute_task",