515
+ 514
+515
516
517
518
@@ -9259,8 +9260,7 @@
534
535
536
-537
-538 | @work_pool_app.command()
+537
| @work_pool_app.command()
async def clear_concurrency_limit(
name: str = typer.Argument(..., help="The name of the work pool to update."),
):
@@ -9662,7 +9662,8 @@
Source code in prefect/cli/work_pool.py
- 463
+ 462
+463
464
465
466
@@ -9679,8 +9680,7 @@
477
478
479
-480
-481 | @work_pool_app.command()
+480
| @work_pool_app.command()
async def delete(
name: str = typer.Argument(..., help="The name of the work pool to delete."),
):
@@ -9729,7 +9729,8 @@
Source code in prefect/cli/work_pool.py
- 541
+ 540
+541
542
543
544
@@ -9761,8 +9762,7 @@ 570
571
572
-573
-574 | @work_pool_app.command()
+573
| @work_pool_app.command()
async def get_default_base_job_template(
type: str = typer.Option(
None,
@@ -9941,8 +9941,7 @@
287
288
289
-290
-291
| @work_pool_app.command()
+290
| @work_pool_app.command()
async def inspect(
name: str = typer.Argument(..., help="The name of the work pool to inspect."),
):
@@ -9957,10 +9956,9 @@
async with get_client() as client:
try:
pool = await client.read_work_pool(work_pool_name=name)
- except ObjectNotFound as exc:
- exit_with_error(exc)
-
- app.console.print(Pretty(pool))
+ app.console.print(Pretty(pool))
+ except ObjectNotFound:
+ exit_with_error(f"Work pool {name!r} not found!")
|
@@ -10116,7 +10114,8 @@
Source code in prefect/cli/work_pool.py
- 294
+ 293
+294
295
296
297
@@ -10138,8 +10137,7 @@
313
314
315
-316
-317 | @work_pool_app.command()
+316
| @work_pool_app.command()
async def pause(
name: str = typer.Argument(..., help="The name of the work pool to pause."),
):
@@ -10193,7 +10191,8 @@
Source code in prefect/cli/work_pool.py
- 577
+ 576
+577
578
579
580
@@ -10259,8 +10258,7 @@
640
641
642
-643
-644 | @work_pool_app.command()
+643
| @work_pool_app.command()
async def preview(
name: str = typer.Argument(None, help="The name or ID of the work pool to preview"),
hours: int = typer.Option(
@@ -10360,7 +10358,8 @@
Source code in prefect/cli/work_pool.py
- 403
+ 402
+403
404
405
406
@@ -10416,8 +10415,7 @@
456
457
458
-459
-460 | @work_pool_app.command(aliases=["provision-infra"])
+459
| @work_pool_app.command(aliases=["provision-infra"])
async def provision_infrastructure(
name: str = typer.Argument(
..., help="The name of the work pool to provision infrastructure for."
@@ -10505,7 +10503,8 @@
Source code in prefect/cli/work_pool.py
- 320
+ 319
+320
321
322
323
@@ -10527,8 +10526,7 @@
339
340
341
-342
-343 | @work_pool_app.command()
+342
| @work_pool_app.command()
async def resume(
name: str = typer.Argument(..., help="The name of the work pool to resume."),
):
@@ -10582,7 +10580,8 @@
Source code in prefect/cli/work_pool.py
- 484
+ 483
+484
485
486
487
@@ -10609,8 +10608,7 @@
508
509
510
-511
-512 | @work_pool_app.command()
+511
| @work_pool_app.command()
async def set_concurrency_limit(
name: str = typer.Argument(..., help="The name of the work pool to update."),
concurrency_limit: int = typer.Argument(
@@ -10669,7 +10667,8 @@
Source code in prefect/cli/work_pool.py
- 346
+ 345
+346
347
348
349
@@ -10722,8 +10721,7 @@
396
397
398
-399
-400 | @work_pool_app.command()
+399
|
+
+
+
+
+
+
+ PREFECT_EXPERIMENTAL_ENABLE_ARTIFACTS_ON_FLOW_RUN_GRAPH = Setting(bool, default=False)
+
+
+ module-attribute
+
+
+
+
+
+
+
+ Whether or not to enable artifacts on the flow run graph.
+
+
+
+
+
+
+
+
PREFECT_EXPERIMENTAL_ENABLE_EVENTS_CLIENT = Setting(bool, default=True)
@@ -15995,18 +16081,7 @@
Source code in prefect/settings.py
- 1561
-1562
-1563
-1564
-1565
-1566
-1567
-1568
-1569
-1570
-1571
-1572
+ 1572
1573
1574
1575
@@ -16148,7 +16223,18 @@
1711
1712
1713
-1714 | @add_cloudpickle_reduction
+1714
+1715
+1716
+1717
+1718
+1719
+1720
+1721
+1722
+1723
+1724
+1725
| @add_cloudpickle_reduction
class Settings(SettingsFieldsMixin):
"""
Contains validated Prefect settings.
@@ -16334,14 +16420,14 @@
Source code in prefect/settings.py
- 1580
-1581
-1582
-1583
-1584
-1585
-1586
-1587 | def value_of(self, setting: Setting[T], bypass_callback: bool = False) -> T:
+ 1591
+1592
+1593
+1594
+1595
+1596
+1597
+1598 | def value_of(self, setting: Setting[T], bypass_callback: bool = False) -> T:
"""
Retrieve a setting's value.
"""
@@ -16372,18 +16458,18 @@
Source code in prefect/settings.py
- 1596
-1597
-1598
-1599
-1600
-1601
-1602
-1603
-1604
-1605
-1606
-1607 | @root_validator
+ 1607
+1608
+1609
+1610
+1611
+1612
+1613
+1614
+1615
+1616
+1617
+1618 | @root_validator
def post_root_validators(cls, values):
"""
Add root validation functions for settings here.
@@ -16418,23 +16504,23 @@
Source code in prefect/settings.py
- 1641
-1642
-1643
-1644
-1645
-1646
-1647
-1648
-1649
-1650
-1651
-1652
+ 1652
1653
1654
1655
1656
-1657 | def with_obfuscated_secrets(self):
+1657
+1658
+1659
+1660
+1661
+1662
+1663
+1664
+1665
+1666
+1667
+1668
| def with_obfuscated_secrets(self):
"""
Returns a copy of this settings object with secret setting values obfuscated.
"""
@@ -16475,13 +16561,13 @@
Source code in prefect/settings.py
- 1659
-1660
-1661
-1662
-1663
-1664
-1665 | def hash_key(self) -> str:
+ 1670
+1671
+1672
+1673
+1674
+1675
+1676 | def hash_key(self) -> str:
"""
Return a hash key for the settings object. This is needed since some
settings may be unhashable. An example is lists.
@@ -16583,18 +16669,7 @@
Source code in prefect/settings.py
- 1667
-1668
-1669
-1670
-1671
-1672
-1673
-1674
-1675
-1676
-1677
-1678
+ 1678
1679
1680
1681
@@ -16627,7 +16702,18 @@ 1708
1709
1710
-1711 | def to_environment_variables(
+1711
+1712
+1713
+1714
+1715
+1716
+1717
+1718
+1719
+1720
+1721
+1722
| def to_environment_variables(
self, include: Iterable[Setting] = None, exclude_unset: bool = False
) -> Dict[str, str]:
"""
@@ -16707,18 +16793,7 @@
Source code in prefect/settings.py
- 1819
-1820
-1821
-1822
-1823
-1824
-1825
-1826
-1827
-1828
-1829
-1830
+ 1830
1831
1832
1833
@@ -16767,7 +16842,18 @@
1876
1877
1878
-1879 | class Profile(BaseModel):
+1879
+1880
+1881
+1882
+1883
+1884
+1885
+1886
+1887
+1888
+1889
+1890
| class Profile(BaseModel):
"""
A user profile containing settings.
"""
@@ -16884,18 +16970,18 @@
Source code in prefect/settings.py
- 1845
-1846
-1847
-1848
-1849
-1850
-1851
-1852
-1853
-1854
-1855
-1856 | def validate_settings(self) -> None:
+ 1856
+1857
+1858
+1859
+1860
+1861
+1862
+1863
+1864
+1865
+1866
+1867 | def validate_settings(self) -> None:
"""
Validate the settings contained in this profile.
@@ -16932,25 +17018,25 @@
Source code in prefect/settings.py
- 1858
-1859
-1860
-1861
-1862
-1863
-1864
-1865
-1866
-1867
-1868
-1869
+ |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|