(self, reason: str)
return self.df.close(reason)
(1) dump pending requests to disk if there is a disk queue
        (2) return the result of the dupefilter's ``close`` method
(1) dump pending requests to disk if there is a disk queue
        (2) return the result of the dupefilter's ``close`` method
( 1 ) dump pending requests to disk if there is a disk queue ( 2 ) return the result of the dupefilter s close method
def close(self, reason: str) -> Optional[Deferred]:
        """
        (1) dump pending requests to disk if there is a disk queue
        (2) return the result of the dupefilter's ``close`` method
        """
        if self.dqs is not None:
            state = self.dqs.close()
            assert isinstance(self.dqdir, str)
            self._write_dqs_state(self.dqdir, state)
        return self.df.close(reason)
def close ( self , reason : str ) -> Optional [ Deferred ] : if self . dqs is not None : state = self . dqs . close ( ) assert isinstance ( self . dqdir , str ) self . _write_dqs_state ( self . dqdir , state ) return self . df . close ( reason )