Distributed collections¶
skyward.dict(name, *, consistency=None)
¶
Get or create a distributed dictionary (runtime shortcut).
Must be called from within a @sky.function running on a pool.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
name
|
str
|
Unique identifier for this collection. |
required |
consistency
|
Consistency | None
|
Consistency level. |
None
|
Returns:
| Type | Description |
|---|---|
DictProxy
|
Synchronous dict-like proxy. |
Examples:
skyward.set(name, *, consistency=None)
¶
Get or create a distributed set (runtime shortcut).
Must be called from within a @sky.function running on a pool.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
name
|
str
|
Unique identifier for this collection. |
required |
consistency
|
Consistency | None
|
Consistency level. |
None
|
Returns:
| Type | Description |
|---|---|
SetProxy
|
Synchronous set-like proxy. |
skyward.counter(name, *, consistency=None)
¶
Get or create a distributed counter (runtime shortcut).
Must be called from within a @sky.function running on a pool.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
name
|
str
|
Unique identifier for this collection. |
required |
consistency
|
Consistency | None
|
Consistency level. |
None
|
Returns:
| Type | Description |
|---|---|
CounterProxy
|
Synchronous counter proxy. |
skyward.queue(name)
¶
Get or create a distributed FIFO queue (runtime shortcut).
Must be called from within a @sky.function running on a pool.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
name
|
str
|
Unique identifier for this collection. |
required |
Returns:
| Type | Description |
|---|---|
QueueProxy
|
Synchronous queue proxy. |
skyward.barrier(name, n)
¶
Get or create a distributed barrier (runtime shortcut).
Must be called from within a @sky.function running on a pool.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
name
|
str
|
Unique identifier for this barrier. |
required |
n
|
int
|
Number of participants that must arrive before releasing. |
required |
Returns:
| Type | Description |
|---|---|
BarrierProxy
|
Synchronous barrier proxy. |
skyward.lock(name, timeout=30)
¶
Get or create a distributed lock (runtime shortcut).
Must be called from within a @sky.function running on a pool.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
name
|
str
|
Unique identifier for this lock. |
required |
timeout
|
float
|
Maximum seconds to wait for acquisition. Default |
30
|
Returns:
| Type | Description |
|---|---|
LockProxy
|
Synchronous lock proxy (supports context manager). |