leaf_focus/pipeline/prefect_flow/construct.py
def run_pdf(
        self,
        feed_dir: Path,
        base_dir: Path,
        pdf_info_exe: Path,
        pdf_text_exe: Path,
        pdf_image_exe: Path,
        serial: bool = False,
    ):
        """Run the pdf Prefect flow."""
        flow = self.build_pdf(base_dir, pdf_info_exe, pdf_text_exe, pdf_image_exe)

        if not serial:
            dask_executor = DaskExecutor()
            flow.run(executor=dask_executor, feed_dir=feed_dir)
        else:
            flow.run(feed_dir=feed_dir)
Run the pdf Prefect flow.
Run the pdf Prefect flow.
Run the pdf Prefect flow .
def run_pdf(
        self,
        feed_dir: Path,
        base_dir: Path,
        pdf_info_exe: Path,
        pdf_text_exe: Path,
        pdf_image_exe: Path,
        serial: bool = False,
    ):
        flow = self.build_pdf(base_dir, pdf_info_exe, pdf_text_exe, pdf_image_exe)
        if not serial:
            dask_executor = DaskExecutor()
            flow.run(executor=dask_executor, feed_dir=feed_dir)
        else:
            flow.run(feed_dir=feed_dir)
def run_pdf ( self , feed_dir : Path , base_dir : Path , pdf_info_exe : Path , pdf_text_exe : Path , pdf_image_exe : Path , serial : bool = False , ) : flow = self . build_pdf ( base_dir , pdf_info_exe , pdf_text_exe , pdf_image_exe ) if not serial : dask_executor = DaskExecutor ( ) flow . run ( executor = dask_executor , feed_dir = feed_dir ) else : flow . run ( feed_dir = feed_dir )
Run the pdf Prefect flow.
Run the pdf Prefect flow .
"""Run the pdf Prefect flow."""
self
feed_dir
Path
base_dir
Path
pdf_info_exe
Path
pdf_text_exe
Path
pdf_image_exe
Path
serial
bool