https://prefect.io logo
Docs
Join the conversationJoin Slack
Channels
announcements
ask-marvin
best-practices-coordination-plane
data-ecosystem
data-tricks-and-tips
events
find-a-prefect-job
geo-australia
geo-bay-area
geo-berlin
geo-boston
geo-chicago
geo-colorado
geo-dc
geo-israel
geo-japan
geo-london
geo-nyc
geo-seattle
geo-texas
gratitude
introductions
marvin-in-the-wild
prefect-ai
prefect-aws
prefect-azure
prefect-cloud
prefect-community
prefect-contributors
prefect-dbt
prefect-docker
prefect-gcp
prefect-getting-started
prefect-integrations
prefect-kubernetes
prefect-recipes
prefect-server
prefect-ui
random
show-us-what-you-got
Powered by Linen
prefect-contributors
  • m

    Marcin Grzybowski

    05/30/2022, 9:36 AM
    Hello all, I have just created my first opensource merge request and it's for Prefect !! https://github.com/PrefectHQ/prefect/pull/5846 Just a really tiny fix, but it feels good =]
    🥇 2
    🙌 2
    a
    c
    k
    • 4
    • 9
  • m

    Marcin Grzybowski

    05/30/2022, 4:52 PM
    Hi - I need a possibility to run multiple snowflake queries in one session and sometimes in a transaction I can probably easily add this - add parameter in SnowflakeQuery class: • transaction: bool = false • change query to queries that takes list of strings with queries - but this is not good for backward compatibility... I can maybe change that query is str or List[str]. Or maybe add another parameter: queries that will be taken into account when query is None.. or something But please let me know if this makes sense for you and if it has a chance to me merged when finished
    a
    • 2
    • 9
  • s

    Stéphan Taljaard

    05/31/2022, 1:57 PM
    Hi I ran the failed test here locally, successfully. Can someone please help me fix what's broken / have a look?
    a
    • 2
    • 6
  • m

    Marcin Grzybowski

    06/02/2022, 10:20 AM
    Hi, I have just created pull request with my proposal that allows to run multiple snowflake queries in one sessions and in a transaction: Maybe someone will be interested 🙂 https://github.com/PrefectHQ/prefect-snowflake/pull/9
    🙌 2
    ❄️ 1
    a
    a
    • 3
    • 3
  • e

    Edmondo Porcu

    07/03/2022, 8:59 PM
    Hi, I have seen Prefect does not use pipenv nor poetry. How do you virtualize the environments when working directly with pip? Do you use virtualenv to create multiple python distributions and then work with plain pip?
    a
    • 2
    • 5
  • a

    ale

    07/14/2022, 12:23 PM
    Hey folks 👋 If you are on Prefect 2.0 and you use Stitch to replicate your data, then you might find this new Prefect collection helpful!
    👀 2
    🙌 3
    :thank-you: 2
    💯 2
    a
    • 2
    • 1
  • a

    ale

    07/24/2022, 5:55 PM
    Hey folks 👋 I’m currently working on an integration between Prefect 2.0 and MetricFlow. For testing purposes, I use
    pyfakefs
    , so that I can mock files on the file system. However, it seems something is not working as expected. It seems related to
    pyfakefs
    and
    prefect
    , but I’m not 100% sure. Anyone able to help me figuring out what’s going on? 😊 Stack trace in the thread! Thanks! 🙌
    a
    • 2
    • 6
  • a

    ale

    07/25/2022, 11:55 AM
    Hey folk 👋 Here’s the first release of the integration between Prefect 2.0 and MetricFlow 🎉
    :marvin-duck: 4
    🚀 5
    🎉 4
    :thank-you: 1
    a
    • 2
    • 1
  • a

    ale

    07/25/2022, 4:19 PM
    Hey folks 👋 I have a bunch of Prefect collections that might be useful to the whole community once people migrate to Prefect 2.0. How can I make my collections listed on the Prefect Collections landing page? 😊
    🎉 4
    :party-parrot: 2
    🔥 2
    j
    j
    +2
    • 5
    • 10
  • s

    Sana Shaikh

    07/28/2022, 5:26 PM
    message has been deleted
    ✅ 1
  • e

    Edmondo Porcu

    08/17/2022, 5:04 PM
    Is Prefect 2.0 still using pip or poetry?
    a
    m
    • 3
    • 3
  • e

    Edmondo Porcu

    08/19/2022, 10:23 PM
    Hi, why was this closed ? https://github.com/PrefectHQ/prefect/pull/6009
    a
    a
    • 3
    • 6
  • m

    Marcin Grzybowski

    08/22/2022, 11:47 AM
    Hi, I have just created https://github.com/PrefectHQ/prefect-snowflake/pull/29 that effectively enables running more than 4-5 concurrent snowflake queries
    :thank-you: 1
    🎉 2
    🙌 4
    👍 1
  • e

    Edmondo Porcu

    08/30/2022, 6:36 PM
    Any chance we can get a release of 1.3.x?
    j
    m
    • 3
    • 3
  • a

    ale

    09/02/2022, 11:17 AM
    Hey folks 👋 I want to build a new collection with a task that execute a CLI command. Should I build the new collection by extending the
    prefect-shell
    one, or should I stark from scratch? If I extend
    prefect-shell
    , should I create my own task and use the
    shell_run_command
    inside my task? Quick example:
    from prefect_shell import shell_run_command
    
    @task 
    def my_shell_task(command: str):
        return shell_run_command(command=command)
    Would this work if I call
    my_shell_task
    in a flow?
    🙌 1
    a
    • 2
    • 4
  • a

    ale

    09/22/2022, 8:15 PM
    Anyone willing to build an integration with Hex?? They’ve just announced v1 of their brand new public APIs. I’m definitely available to help!
    👀 2
    🎉 3
    👍 1
    b
    a
    i
    • 4
    • 5
  • m

    Michael Adkins

    09/28/2022, 6:29 PM
    Hi! I’m really curious if anyone in this group would be affected by the breaking change presented in https://github.com/PrefectHQ/prefect/pull/6926 tldr; are you calling
    State.result()
    in an async context? (does not apply to
    Future.result()
    )
    👍 1
  • a

    ale

    09/29/2022, 3:20 PM
    Hey folks 👋 Cross posting from the Soda community --> https://soda-community.slack.com/archives/C02PC0WPRNC/p1664464535579609 Spoiler: Soda released a new Prefect collection that you can use to run data quality checks on your data! Thanks to Soda to provide me the opportunity to collaborate with them on this new collection! 🚀 🚀
    👍 3
    :thank-you: 1
    ❤️ 1
    🙏 2
    👏 2
    🙌 4
    :party-parrot: 4
    a
    j
    • 3
    • 5
  • d

    davzucky

    10/02/2022, 12:09 PM
    Just published a new collection that allows monitoring the prefect server using opentelemetry. This is an initial version that publishes trace only at the moment on the server. https://pypi.org/project/prefect-opentelemetry/ github project https://github.com/davzucky/prefect-opentelemetry The next steps are • Add metrics • Enable Agent to support OTEL • Create a block for OTEL • Create a custom task that would generate traces on the run (Would be nice to be able o add plugins) on flow or task to do that. Please share your feedback
    🔥 6
    :thank-you: 2
    ❤️ 2
    c
    a
    +2
    • 5
    • 4
  • m

    Michael Adkins

    10/05/2022, 3:34 PM
    👋 You may have noticed I’m working on result configuration. There’s a bit more wiring up to do but the documentation is in a near-final form. Check out the preview at https://deploy-preview-6908--prefect-orion.netlify.app/concepts/results/ — feel free to share any feedback!
    :thank-you: 4
    :blob-attention-gif: 2
    :party-parrot: 1
    👍 3
    j
    o
    • 3
    • 5
  • a

    Anna Geller

    10/05/2022, 5:24 PM
    Happy Hacktoberfest! 🍻 Cross-posting that OpenMetadata and Airbyte are celebrating by giving 💰 and swag for contributing connectors. Specifically for OpenMetadata, if you are interested in helping contribute, QA or build examples/tutorials for the integration, feel free to ping me. Thanks to all contributors! 💙
  • t

    Thomas Fredriksen

    10/10/2022, 12:20 PM
    Hi there, I have created a redis collection and am looking for the steps needed to become a part of the official prefect packages: https://github.com/C4IROcean/prefect-redis @alex - @Anna Geller mentioned you could help with this? https://prefect-community.slack.com/archives/CL09KU1K7/p1665169933380519?thread_ts=1665131857.359879&cid=CL09KU1K7
    :party-parrot: 3
    :prefect-duck: 2
    🙌 6
    🎉 3
    a
    a
    • 3
    • 19
  • a

    ale

    12/07/2022, 7:57 AM
    Hey folks 👋 Recently I started working on a new integration. I’ve started from the
    prefect-collection-template
    as usual. From time to time, I’m seeing the failures on the Github Action named “_Template Synchronization_”. The reported error is
    Run tibdex/github-app-token@v1
      with:
        github_api_url: <https://api.github.com>
        repository: AlessandroLollo/prefect-sifflet
      env:
        pythonLocation: /opt/hostedtoolcache/Python/3.9.15/x64
        PKG_CONFIG_PATH: /opt/hostedtoolcache/Python/3.9.15/x64/lib/pkgconfig
        Python_ROOT_DIR: /opt/hostedtoolcache/Python/3.9.15/x64
        Python2_ROOT_DIR: /opt/hostedtoolcache/Python/3.9.15/x64
        Python3_ROOT_DIR: /opt/hostedtoolcache/Python/3.9.15/x64
        LD_LIBRARY_PATH: /opt/hostedtoolcache/Python/3.9.15/x64/lib
    Error: Error: Input required and not supplied: app_id
    Anyone knows how to solve it? Thanks! 🙌
    a
    • 2
    • 2
  • a

    ale

    12/15/2022, 8:47 PM
    Been working on an integration between Sifflet and Prefect. Not released yet, but you can find the code here. Feedbacks more than welcome as usual! 🙌 cc @Wajdi
    🙌 4
    :gratitude-thank-you: 2
    :party-parrot: 2
    :upvote: 5
    💯 5
    :blob-attention-gif: 4
  • s

    Stefano Cascavilla

    12/16/2022, 12:52 PM
    Hey everyone 👋 I'm working on a general purpose integration between Google Sheets and Prefect. I've a first version ready and would like to publish it. I've read from the docs that I have to open a PR to the Prefect repo with a new yaml file under the
    collections/catalog
    path. My question is: how can I publish it on PyPi? Is there any automation? Something related to Github action? Thanks! 😄
    🙌 6
    :blob-attention-gif: 2
    :party-parrot: 1
    a
    a
    +2
    • 5
    • 10
  • s

    Senthil M.K.

    01/17/2023, 11:42 PM
    Hello, what's the status on the prefect-twilio project? Has not been any activity for the past 7 months...and PYPI does not have a package which can be installed via pip
    m
    a
    • 3
    • 4
  • a

    ale

    01/29/2023, 8:56 PM
    Hey folks 👋 I’m working on a new integration between Prefect and Huggingface 🚀 Here’s the code! Right now it only support Inference API, but I’m planning to extend it to support also Inference Endpoints
    🙌 6
    🔥 7
    👍 3
    :gratitude-thank-you: 2
    ⭐ 3
    j
    a
    • 3
    • 3
  • j

    Jaime Raldua Veuthey

    02/03/2023, 7:28 AM
    Hi, Maybe not smart questions but I didn't see them quick scrolling in the channel... how does one start when wanting to contribute? Is there a list of on-going projects where one can do PRs? Is there a list with prioritized projects based on demand of feature requests or something like that? Is it more useful contributing with a new Block, or with something else? Thanks!
    ✅ 1
    p
    • 2
    • 1
  • a

    ale

    02/06/2023, 1:44 PM
    Hey folks 👋 I’m getting these warnings while running tests on a new collection I’m working on
    ../../../.pyenv/versions/3.10.9/envs/prefect-huggingface/lib/python3.10/site-packages/prefect/testing/standard_test_suites/task_runners.py:155
      /Users/alessandro.lollo/.pyenv/versions/3.10.9/envs/prefect-huggingface/lib/python3.10/site-packages/prefect/testing/standard_test_suites/task_runners.py:155: PytestUnknownMarkWarning: Unknown pytest.mark.flaky - is this a typo?  You can register custom marks to avoid this warning - for details, see <https://docs.pytest.org/en/stable/how-to/mark.html>
        @pytest.mark.flaky(max_runs=4)  # Threads do not consistently yield
    Not sure what’s the issue here, anyone experiencing this?
    tests/test_tasks.py::test_get_inference_result_fails
      /Users/alessandro.lollo/.pyenv/versions/3.10.9/envs/prefect-huggingface/lib/python3.10/site-packages/prefect/orion/database/migrations/versions/sqlite/2022_04_25_135207_b75d279ba985_replace_version_with_checksum.py:102: RemovedIn20Warning: Deprecated API features detected! These feature(s) are not compatible with SQLAlchemy 2.0. To prevent incompatible upgrades prior to updating applications, ensure requirements files are pinned to "sqlalchemy<2.0". Set environment variable SQLALCHEMY_WARN_20=1 to show all deprecation warnings.  Set environment variable SQLALCHEMY_SILENCE_UBER_WARNING=1 to silence this message. (Background on SQLAlchemy 2.0 at: <https://sqlalche.me/e/b8d9>)
        meta_data = sa.MetaData(bind=connection)
    
    tests/test_tasks.py::test_get_inference_result_fails
      /Users/alessandro.lollo/.pyenv/versions/3.10.9/lib/python3.10/contextlib.py:142: SAWarning: Skipped unsupported reflection of expression-based index ix_flow_run__coalesce_start_time_expected_start_time_desc
        next(self.gen)
    
    tests/test_tasks.py::test_get_inference_result_fails
      /Users/alessandro.lollo/.pyenv/versions/3.10.9/lib/python3.10/contextlib.py:142: SAWarning: Skipped unsupported reflection of expression-based index ix_flow_run__coalesce_start_time_expected_start_time_asc
        next(self.gen)
    
    -- Docs: <https://docs.pytest.org/en/stable/how-to/capture-warnings.html>
    These seems to be related to SQLAlchemy 2.0. However, in my environment I have
    prefect==2.7.11
    and
    sqlalchemy==1.4.46
    Anyone experiencing the same? Is this something I should be worried about? 😅
    ✅ 1
    a
    a
    m
    • 4
    • 4
  • w

    Wajdi

    02/20/2023, 4:24 PM
    Hey folks 👋, I am excited to announce that the integration between Prefect and Sifflet has been released: https://github.com/Siffletapp/prefect-sifflet . Sifflet is a full data stack observability; this integration is the first of many steps toward prefect data pipeline observability. I want to take a moment and thank @ale for leading this integration; it was a real plaisir working with him. We look forward to continuing our collaboration with you and other members of the open-source community.
    🎉 3
    👏 4
    🙌 3
    ❤️ 2
    👀 2
    a
    t
    • 3
    • 2
Powered by Linen
Title
w

Wajdi

02/20/2023, 4:24 PM
Hey folks 👋, I am excited to announce that the integration between Prefect and Sifflet has been released: https://github.com/Siffletapp/prefect-sifflet . Sifflet is a full data stack observability; this integration is the first of many steps toward prefect data pipeline observability. I want to take a moment and thank @ale for leading this integration; it was a real plaisir working with him. We look forward to continuing our collaboration with you and other members of the open-source community.
🎉 3
👏 4
🙌 3
❤️ 2
👀 2
a

Anna Geller

02/20/2023, 6:54 PM
Thank you so much @Wajdi and @ale for contributing! very cool to see a custom block here as well! @alex we might want to add a logo URL, I forgot how it's done https://github.com/Siffletapp/prefect-sifflet/blob/main/prefect_sifflet/credentials.py#L29 cc @terrence would be great to add to the catalog 🙏
✅ 1
t

terrence

02/21/2023, 1:59 PM
On it.
:gratitude-thank-you: 3
🙌 3
View count: 1