[pull] main from PrefectHQ:main #16

pull · 2023-02-01T21:21:45Z

See Commits and Changes for more details.

Created by pull[bot] (v2.0.0-alpha.1)

Can you help keep this open source service alive? 💖 Please sponsor : )

docs/overrides/partials/integrations/analytics/custom.html

+</script>
+<!-- Segment analytics -->
+<script>
+    !function(){var analytics=window.analytics=window.analytics||[];if(!analytics.initialize)if(analytics.invoked)window.console&&console.error&&console.error("Segment snippet included twice.");else{analytics.invoked=!0;analytics.methods=["trackSubmit","trackClick","trackLink","trackForm","pageview","identify","reset","group","track","ready","alias","debug","page","once","off","on","addSourceMiddleware","addIntegrationMiddleware","setAnonymousId","addDestinationMiddleware"];analytics.factory=function(e){return function(){var t=Array.prototype.slice.call(arguments);t.unshift(e);analytics.push(t);return analytics}};for(var e=0;e<analytics.methods.length;e++){var key=analytics.methods[e];analytics[key]=analytics.factory(key)}analytics.load=function(key,e){var t=document.createElement("script");t.type="text/javascript";t.async=!0;t.src="https://cdn.segment.com/analytics.js/v1/" + key + "/analytics.min.js";var n=document.getElementsByTagName("script")[0];n.parentNode.insertBefore(t,n);analytics._loadOptions=e};analytics._writeKey="xDLAoTXsNYpC4Y6JucKnJ8W1MYBuyAbD";;analytics.SNIPPET_VERSION="4.15.3";


flows/agent.py

+        subprocess.run(["prefect", "work-queue", "create", "test"])
+        try:
+            subprocess.run(["prefect", "agent", "start", "test"], timeout=30)
+        except subprocess.TimeoutExpired:


flows/agent.py

+            subprocess.run(
+                ["prefect", "agent", "start", "--work-queue", "default"], timeout=30
+            )
+        except subprocess.TimeoutExpired:


src/prefect/events/clients.py

+
+    @abc.abstractmethod
+    async def _emit(self, event: Event) -> None:  # pragma: no cover
+        ...


src/prefect/events/clients.py

+
+        # make sure we have actually connected
+        pong = await self._websocket.ping()
+        await pong


src/prefect/events/clients.py

+            return
+
+        pong = await self._websocket.ping()
+        await pong


src/prefect/cli/work_pool.py

+    table.add_column("Name", style="green", no_wrap=True)
+    table.add_column("Deployment ID", style="blue", no_wrap=True)
+
+    window = pendulum.now("utc").add(hours=hours or 1)


src/prefect/results.py

        block_document = await client.read_block_document(self.storage_block_id)
        storage_block: ReadableFileSystem = Block._from_block_document(block_document)
        content = await storage_block.read_path(self.storage_key)
        blob = PersistedResultBlob.parse_raw(content)
        return blob

+    @classmethod
+    def _infer_path(cls, storage_block, key) -> str:


src/prefect/_internal/concurrency/supervisors.py

+    def __post_init__(self):
+        logger.debug("Created work item %r", self)
+
+    def run(self):


src/prefect/_internal/concurrency/supervisors.py

+
+            result = work_item.run()
+            if inspect.isawaitable(result):
+                await result


Co-authored-by: Fabian Nobis <fabian.nobis@deutschebahn.com>

Co-authored-by: daniel-prefect <daniel@prefect.io>

…#16913)

Co-authored-by: Devan Grose <=>

Co-authored-by: Alex Streed <desertaxle@users.noreply.github.com>

Co-authored-by: daniel-prefect <daniel@prefect.io> Co-authored-by: nate nowack <thrast36@gmail.com>

Co-authored-by: Alex Streed <alex.s@prefect.io>

Co-authored-by: marvin-robot <marvin-robot@users.noreply.github.com>

Co-authored-by: Devan Grose <=>

…space set` (#17296)

…17297)

… pools and work queues links (#17294)

…17295)

Co-authored-by: Chris Pickett <chris.pickett@prefect.io>

Co-authored-by: Kevin Grismore <146098880+kevingrismore@users.noreply.github.com>

Co-authored-by: marvin-robot <marvin-robot@users.noreply.github.com>

Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

Co-authored-by: daniel-prefect <daniel@prefect.io>

Co-authored-by: daniel-prefect <daniel@prefect.io> Co-authored-by: Jenny G <40272060+zhen0@users.noreply.github.com> Co-authored-by: Jeff Hale <discdiver@users.noreply.github.com>

pull bot added the ⤵️ pull label Feb 1, 2023

github-advanced-security bot found potential problems Feb 13, 2023

View reviewed changes

github-advanced-security bot found potential problems Feb 15, 2023

View reviewed changes

github-advanced-security bot found potential problems Feb 17, 2023

View reviewed changes

pull bot added the merge-conflict Resolve conflicts manually label Mar 1, 2023

NobisIndustries and others added 24 commits January 30, 2025 10:37

Add event resources to the event cleanup cycle (#16907)

c4ba671

Co-authored-by: Fabian Nobis <fabian.nobis@deutschebahn.com>

[UI v2] feat: Adds useLocalStorage hook (#16900)

a2362a2

Add section on UI settings for proxies (#16912)

3ac3d54

Co-authored-by: daniel-prefect <daniel@prefect.io>

more pendulum consolidation (#16911)

c590d61

Consolidates discovery of Prefect server Services to the base class (…

ffa9951

…#16913)

feat: artifacts api RQ and stub route (#16893)

fc5a185

Co-authored-by: Devan Grose <=>

rm duplicative use of word in README (#16909)

0b321b4

Reject task run state change if the cache key is too large (#16914)

879747a

fix emit_event docstring (#16918)

a567b6e

Update @prefecthq/prefect-ui-library to version 3.11.39 (#16919)

b48b774

Bump vite from 6.0.3 to 6.0.11 in /ui (#16798)

4f41654

Bump typescript from 5.7.2 to 5.7.3 in /ui (#16694)

da6a517

Fix prefect-dask test suite (#16920)

5b5725a

Bumps to ruff==0.9.2 and mypy==1.14.1 (#16916)

81f952d

Co-authored-by: Alex Streed <desertaxle@users.noreply.github.com>

Remove unused function (#16923)

ad29cac

Enhancement: Add New SLA Types (#16902)

0d553de

Co-authored-by: daniel-prefect <daniel@prefect.io> Co-authored-by: nate nowack <thrast36@gmail.com>

fix create_markdown_artifact usage in prefect-dbt (#16926)

b87312c

refactor work pool client methods (#16661)

b2534c2

Co-authored-by: Alex Streed <alex.s@prefect.io>

Update @prefecthq/prefect-ui-library to version 3.11.40 (#16929)

daedaf7

Co-authored-by: marvin-robot <marvin-robot@users.noreply.github.com>

[UI v2] feat: Scaffolds UX components for Settings page (#16899)

2e9c2ab

add notes on TASK_SOURCE behavior (#16928)

f8c134e

Add dbt profiles utilities (#16889)

6f768a4

Update @prefecthq/prefect-ui-library to version 3.11.41 (#16930)

471a8c2

Co-authored-by: marvin-robot <marvin-robot@users.noreply.github.com>

more pendulum consolidation (#16922)

26ae729

kevingrismore and others added 30 commits February 26, 2025 10:56

Fix dbt docs typo (#17288)

ae490b0

[UI-v2] feat: add activity graph (#17224)

a8a7a83

Co-authored-by: Devan Grose <=>

[ui-v2] feat: only lint staged changes on pre-commit (#17283)

abef75f

Co-authored-by: Devan Grose <=>

[UI v2] feat: Adds work-pool-select component (#17291)

4d9c0d2

[UI v2] feat: Adds API to retrieve a work pool details (#17292)

e8225a8

[UI v2] feat: Adds GET work queue details API (#17293)

c009630

fix go back to acct for prefect cloud login and `prefect cloud work…

df860d4

…space set` (#17296)

[UI v2] feat: Adds filter API by for work queues by work pool name (#…

ed6cc9f

…17297)

[UI v2] feat: Updates deployment details page to have associated work…

4850083

… pools and work queues links (#17294)

Updates ProcessWorker to delegate flow run execution to a Runner (#…

f4d14f1

…17295)

Upgrade websockets to v15 (#17274)

79cb8b5

Co-authored-by: Chris Pickett <chris.pickett@prefect.io>

[UI v2] feat: Adds Work Queues select component (#17298)

b498b9d

Refresh session when deleting schedules off a deployment (#17278)

c5eef21

[ui-v2] Schema form component (#17166)

accacec

enhance mapping docs (#17269)

b8ff0bb

Co-authored-by: Kevin Grismore <146098880+kevingrismore@users.noreply.github.com>

Subscribe to state changes in wait_for_flow_run (#17243)

29d8afd

fix profile use switching (#17300)

ec16d74

chore(API docs): link to related docs pages (#17276)

8b7f7f2

[ui-v2] Add graph dependency (#17305)

cae5779

[ui-v2] Ignore package files in biome formatting (#17307)

74245d1

Update @prefecthq/prefect-ui-library to version 3.11.43 (#17309)

2d13ade

Co-authored-by: marvin-robot <marvin-robot@users.noreply.github.com>

chore(deps-dev): bump vue-tsc from 2.1.10 to 2.2.4 in /ui (#17254)

2c0860d

Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

add note on docker networking (#17306)

c4e3a0a

Co-authored-by: daniel-prefect <daniel@prefect.io>

[ui-v2] Update graphs package (#17310)

17985d9

Update Vertex worker to accept rich scheduling configuration (#17266)

dc25f37

Fallback to system uv if Python interface isn't available (#17320)

b6d9414

Remove extra example from Vertex AI worker (#17324)

9b1d439

Airflow migration guide (#17285)

cd24d54

Co-authored-by: daniel-prefect <daniel@prefect.io> Co-authored-by: Jenny G <40272060+zhen0@users.noreply.github.com> Co-authored-by: Jeff Hale <discdiver@users.noreply.github.com>

Lift limit on Runner used by ProcessWorker (#17325)

27eb408

fix 3.9 specific flakes (#17326)

af502b4

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[pull] main from PrefectHQ:main #16

[pull] main from PrefectHQ:main #16

pull bot commented Feb 1, 2023 •

edited

Loading

[pull] main from PrefectHQ:main #16

Are you sure you want to change the base?

[pull] main from PrefectHQ:main #16

Conversation

pull bot commented Feb 1, 2023 • edited Loading

pull bot commented Feb 1, 2023 •

edited

Loading