Sanjay Aradhyamath samz5320

## simple_task.py
def read_csv():
    df=pd.read_csv("xyz.csv") #reading a csv file
	return df #returning the dataframe

## basic_workflow_airflow.py
#import
from datetime import timedelta
from airflow import DAG
from datetime import datetime,timedelta
from airflow.operators.dummy_operator import DummyOperator
#import dummyoperator airflow

# define defult dag

default_args={

## simple_task_reg.py
#imports
import prefect
from prefect import task, Flow

#deinfe tasks
@task
def hello():
    print("Hello World!")

#initialize tasks

## Hello_world_prefect.py
from prefect import flow, task

@task
def sampole_task():
    print("Hello_world")
	def read_csv():
	df=pd.read_csv("xyz.csv") #reading a csv file
	return df #returning the dataframe
	#import
	from datetime import timedelta
	from airflow import DAG
	from datetime import datetime,timedelta
	from airflow.operators.dummy_operator import DummyOperator
	#import dummyoperator airflow

	# define defult dag

	default_args={
	#imports
	import prefect
	from prefect import task, Flow

	#deinfe tasks
	@task
	def hello():
	print("Hello World!")

	#initialize tasks
	from prefect import flow, task

	@task
	def sampole_task():
	print("Hello_world")