(self)
| 1883 | return super()._broadcast_dep(dep) |
| 1884 | |
| 1885 | def _divisions(self): |
| 1886 | if not self.is_monotonic: |
| 1887 | # Implement this consistently with dask.dataframe, e.g. add option to |
| 1888 | # control monotonic map func |
| 1889 | return (None,) * len(self.frame.divisions) |
| 1890 | elif is_index_like(self.frame._meta): |
| 1891 | if isinstance(self.arg, Expr): |
| 1892 | return (None,) * len(self.frame.divisions) |
| 1893 | return tuple( |
| 1894 | pd.Series(self.frame.divisions).map(self.arg, na_action=self.na_action) |
| 1895 | ) |
| 1896 | elif isinstance(self.arg, Expr): |
| 1897 | if ( |
| 1898 | self._broadcast_dep(self.arg) |
| 1899 | or self.arg.divisions == self.frame.divisions |
| 1900 | ): |
| 1901 | return self.frame.divisions |
| 1902 | else: |
| 1903 | # We only get here when we have only one partition |
| 1904 | return (None,) * (self.frame.npartitions + 1) |
| 1905 | return super()._divisions() |
| 1906 | |
| 1907 | |
| 1908 | class VarColumns(Elemwise): |
no test coverage detected