Stage a command to be executed when execute() is next called Returns the current Pipeline object back so commands can be chained together, such as: pipe = pipe.set('foo', 'bar').incr('baz').decr('bang') At some other point, you can then run: pipe.execute()
(self, *args, **options)
| 1851 | raise |
| 1852 | |
| 1853 | def pipeline_execute_command(self, *args, **options): |
| 1854 | """ |
| 1855 | Stage a command to be executed when execute() is next called |
| 1856 | |
| 1857 | Returns the current Pipeline object back so commands can be |
| 1858 | chained together, such as: |
| 1859 | |
| 1860 | pipe = pipe.set('foo', 'bar').incr('baz').decr('bang') |
| 1861 | |
| 1862 | At some other point, you can then run: pipe.execute(), |
| 1863 | which will execute all commands queued in the pipe. |
| 1864 | """ |
| 1865 | self.command_stack.append((args, options)) |
| 1866 | return self |
| 1867 | |
| 1868 | async def _execute_transaction( # noqa: C901 |
| 1869 | self, connection: Connection, commands: CommandStackT, raise_on_error |