Commitce39aaf

authored

gh-99509: Add__class_getitem__ tomultiprocessing.queues.Queue (#99511)

1 parent199507b commitce39aafCopy full SHA for ce39aaf

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -280,6 +280,8 @@ def _on_queue_feeder_error(e, obj):`
`280`	`280`	`importtraceback`
`281`	`281`	`traceback.print_exc()`
`282`	`282`
	`283`	`+__class_getitem__=classmethod(types.GenericAlias)`
	`284`	`+`
`283`	`285`
`284`	`286`	`_sentinel=object()`
`285`	`287`

Lines changed: 6 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -31,11 +31,15 @@`
`31`	`31`	`frommultiprocessing.managersimportValueProxy`
`32`	`32`	`frommultiprocessing.poolimportApplyResult`
`33`	`33`	`frommultiprocessing.queuesimportSimpleQueueasMPSimpleQueue`
	`34`	`+frommultiprocessing.queuesimportQueueasMPQueue`
	`35`	`+frommultiprocessing.queuesimportJoinableQueueasMPJoinableQueue`
`34`	`36`	`exceptImportError:`
`35`	`37`	`# _multiprocessing module is optional`
`36`	`38`	`ValueProxy=None`
`37`	`39`	`ApplyResult=None`
`38`	`40`	`MPSimpleQueue=None`
	`41`	`+MPQueue=None`
	`42`	`+MPJoinableQueue=None`
`39`	`43`	`try:`
`40`	`44`	`frommultiprocessing.shared_memoryimportShareableList`
`41`	`45`	`exceptImportError:`
`@@ -130,7 +134,8 @@ class BaseTest(unittest.TestCase):`
`130`	`134`	`ifctypesisnotNone:`
`131`	`135`	`generic_types.extend((ctypes.Array,ctypes.LibraryLoader))`
`132`	`136`	`ifValueProxyisnotNone:`
`133`		`-generic_types.extend((ValueProxy,ApplyResult,MPSimpleQueue))`
	`137`	`+generic_types.extend((ValueProxy,ApplyResult,`
	`138`	`+MPSimpleQueue,MPQueue,MPJoinableQueue))`
`134`	`139`
`135`	`140`	`deftest_subscriptable(self):`
`136`	`141`	`fortinself.generic_types:`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	+Add:pep:`585` support for:class:`multiprocessing.queues.Queue`.

Comments

(0)